You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2017/01/09 15:24:53 UTC
[17/34] qpid-proton git commit: PROTON-1385: remove proton-j from the
existing repo, it now has its own repo at:
https://git-wip-us.apache.org/repos/asf/qpid-proton-j.git
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/EndpointState.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/EndpointState.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/EndpointState.java
deleted file mode 100644
index c11da6c..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/EndpointState.java
+++ /dev/null
@@ -1,32 +0,0 @@
-package org.apache.qpid.proton.engine;
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-
-/**
- * Represents the state of a communication endpoint.
- */
-public enum EndpointState
-{
- UNINITIALIZED,
- ACTIVE,
- CLOSED;
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Engine.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Engine.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Engine.java
deleted file mode 100644
index 3bd46ce..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Engine.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-/**
- * Engine
- *
- */
-
-public final class Engine
-{
-
- private Engine()
- {
- }
-
- public static Collector collector()
- {
- return Collector.Factory.create();
- }
-
- public static Connection connection()
- {
- return Connection.Factory.create();
- }
-
- public static Transport transport()
- {
- return Transport.Factory.create();
- }
-
- public static SslDomain sslDomain()
- {
- return SslDomain.Factory.create();
- }
-
- public static SslPeerDetails sslPeerDetails(String hostname, int port)
- {
- return SslPeerDetails.Factory.create(hostname, port);
- }
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
deleted file mode 100644
index 5930d2c..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
+++ /dev/null
@@ -1,175 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.reactor.Reactor;
-import org.apache.qpid.proton.reactor.Selectable;
-import org.apache.qpid.proton.reactor.Task;
-
-
-/**
- * Event
- *
- */
-
-public interface Event extends Extendable
-{
- /**
- * Event types built into the library.
- */
- public enum Type implements EventType {
- REACTOR_INIT,
- REACTOR_QUIESCED,
- REACTOR_FINAL,
-
- TIMER_TASK,
-
- CONNECTION_INIT,
- CONNECTION_BOUND,
- CONNECTION_UNBOUND,
- CONNECTION_LOCAL_OPEN,
- CONNECTION_REMOTE_OPEN,
- CONNECTION_LOCAL_CLOSE,
- CONNECTION_REMOTE_CLOSE,
- CONNECTION_FINAL,
-
- SESSION_INIT,
- SESSION_LOCAL_OPEN,
- SESSION_REMOTE_OPEN,
- SESSION_LOCAL_CLOSE,
- SESSION_REMOTE_CLOSE,
- SESSION_FINAL,
-
- LINK_INIT,
- LINK_LOCAL_OPEN,
- LINK_REMOTE_OPEN,
- LINK_LOCAL_DETACH,
- LINK_REMOTE_DETACH,
- LINK_LOCAL_CLOSE,
- LINK_REMOTE_CLOSE,
- LINK_FLOW,
- LINK_FINAL,
-
- DELIVERY,
-
- TRANSPORT,
- TRANSPORT_ERROR,
- TRANSPORT_HEAD_CLOSED,
- TRANSPORT_TAIL_CLOSED,
- TRANSPORT_CLOSED,
-
- SELECTABLE_INIT,
- SELECTABLE_UPDATED,
- SELECTABLE_READABLE,
- SELECTABLE_WRITABLE,
- SELECTABLE_EXPIRED,
- SELECTABLE_ERROR,
- SELECTABLE_FINAL,
-
- /**
- * This value must never be used to generate an event, it's only used as
- * a guard when casting custom EventTypes to core {@link Type} via
- * {@link Event#getType()}.
- */
- NON_CORE_EVENT {
- @Override
- public boolean isValid() { return false; }
- };
-
- @Override
- public boolean isValid() {
- return true;
- }
- }
-
- /**
- * @return type of the event. The event type can be defined outside of the
- * proton library.
- */
- EventType getEventType();
-
- /**
- * A concrete event type of core events.
- *
- * @return type of the event for core events. For events generated by
- * extensions a {@link Type#NON_CORE_EVENT} will be returned
- */
- Type getType();
-
- Object getContext();
-
- /**
- * The {@link Handler} at the root of the handler tree.
- * <p>
- * Set by the {@link Reactor} before dispatching the event.
- * <p>
- * @see #redispatch(EventType, Handler)
- * @return The root handler
- */
- Handler getRootHandler();
-
- void dispatch(Handler handler) throws HandlerException;
-
- /**
- * Synchronously redispatch the current event as a new {@link EventType} on the provided handler and it's children.
- * <p>
- * Note: the <code>redispatch()</code> will complete before children of the current handler have had the current event dispatched, see {@link #delegate()}.
- *
- *
- * @param as_type Type of event to dispatch
- * @param handler The handler where to start the dispatch. Use {@link #getRootHandler()} to redispatch the new event to all handlers in the tree.
- * @throws HandlerException A wrapper exception of any unhandled exception thrown by <code>handler</code>
- */
- void redispatch(EventType as_type, Handler handler) throws HandlerException;
-
- /**
- * dispatch the event to all children of the handler. A handler can call
- * this method explicitly to be able to do more processing after all child
- * handlers have already processed the event. If handler does not invoke
- * this method it is invoked implicitly by {@link #dispatch(Handler)}
- *
- * @throws HandlerException
- */
- void delegate() throws HandlerException;
-
- Connection getConnection();
-
- Session getSession();
-
- Link getLink();
-
- Sender getSender();
-
- Receiver getReceiver();
-
- Delivery getDelivery();
-
- Transport getTransport();
-
- Reactor getReactor();
-
- Selectable getSelectable();
-
- Task getTask();
-
- Event copy();
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/EventType.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/EventType.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/EventType.java
deleted file mode 100644
index 68ec6e4..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/EventType.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-/**
- * Entry point for external libraries to add event types. Event types should be
- * <code>final static</code> fields. EventType instances are compared by
- * reference.
- * <p>
- * Event types are best described by an <code>enum</code> that implements the
- * {@link EventType} interface, see {@link Event.Type}.
- *
- */
-public interface EventType {
-
- /**
- * @return false if this particular EventType instance does not represent a
- * real event type but a guard value, example: extra enum value for
- * switch statements, see {@link Event.Type#NON_CORE_EVENT}
- */
- public boolean isValid();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Extendable.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Extendable.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Extendable.java
deleted file mode 100644
index 14b9b2e..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Extendable.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-
-/**
- * Extendable
- *
- */
-
-public interface Extendable
-{
-
- Record attachments();
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ExtendableAccessor.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ExtendableAccessor.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ExtendableAccessor.java
deleted file mode 100644
index d2eee03..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ExtendableAccessor.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-/**
- * A typesafe convenience class for associating additional data with {@link Extendable} classes.
- * <p>
- * An instance of <code>ExtendableAccessor</code> uses itself as the key in the {@link Extendable#attachments()}
- * so it's best instantiated as a static final member.
- * <pre><code>
- * class Foo extends BaseHandler {
- * private static ExtendableAccessor<Link, Bar> LINK_BAR = new ExtendableAccessor<>(Bar.class);
- * void onLinkRemoteOpen(Event e) {
- * Bar bar = LINK_BAR.get(e.getLink());
- * if (bar == null) {
- * bar = new Bar();
- * LINK_BAR.set(e.getLink(), bar);
- * }
- * }
- * }
- * </code></pre>
- *
- * @param <E> An {@link Extendable} type where the data is to be stored
- * @param <T> The type of the data to be stored
- */
-public final class ExtendableAccessor<E extends Extendable, T> {
- private final Class<T> klass;
- public ExtendableAccessor(Class<T> klass) {
- this.klass = klass;
- }
-
- public T get(E e) {
- return e.attachments().get(this, klass);
- }
-
- public void set(E e, T value) {
- e.attachments().set(this, klass, value);
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Handler.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Handler.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Handler.java
deleted file mode 100644
index 3a8e5ae..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Handler.java
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import java.util.Iterator;
-
-
-/**
- * Handler
- *
- */
-
-public interface Handler
-{
- /**
- * Handle the event in this instance. This is the second half of
- * {@link Event#dispatch(Handler)}. The method must invoke a concrete onXxx
- * method for the given event, or invoke it's {@link #onUnhandled(Event)}
- * method if the {@link EventType} of the event is not recognized by the
- * handler.
- * <p>
- * <b>Note:</b> The handler is not supposed to invoke the
- * {@link #handle(Event)} method on it's {@link #children()}, that is the
- * responsibility of the {@link Event#dispatch(Handler)}
- *
- * @see BaseHandler
- * @param e
- * The event to handle
- */
- void handle(Event e);
-
- void onUnhandled(Event e);
-
- void add(Handler child);
-
- Iterator<Handler> children();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/HandlerException.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/HandlerException.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/HandlerException.java
deleted file mode 100644
index ca18d7c..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/HandlerException.java
+++ /dev/null
@@ -1,39 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.proton.engine;
-
-
-public class HandlerException extends RuntimeException {
-
- private static final long serialVersionUID = 5300211824119834005L;
-
- private final Handler handler;
-
- public HandlerException(Handler handler, Throwable cause) {
- super(cause);
- this.handler = handler;
- }
-
- public Handler getHandler() {
- return handler;
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
deleted file mode 100644
index 248c687..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
+++ /dev/null
@@ -1,301 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import java.util.EnumSet;
-import java.util.Map;
-
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.transport.ReceiverSettleMode;
-import org.apache.qpid.proton.amqp.transport.SenderSettleMode;
-import org.apache.qpid.proton.amqp.transport.Source;
-import org.apache.qpid.proton.amqp.transport.Target;
-
-/**
- * Link
- *
- * The settlement mode defaults are:
- *
- * Sender settle mode - {@link SenderSettleMode#MIXED}.
- * Receiver settle mode - {@link ReceiverSettleMode#FIRST}
- *
- * TODO describe the application's responsibility to honour settlement.
- */
-public interface Link extends Endpoint
-{
-
- /**
- * Returns the name of the link
- *
- * @return the link name
- */
- String getName();
-
- /**
- * Create a delivery object based on the specified tag and adds it to the
- * this link's delivery list and its connection work list.
- *
- * TODO to clarify - this adds the delivery to the connection list. It is not yet
- * clear why this is done or if it is useful for the application to be able to discover
- * newly created deliveries from the {@link Connection#getWorkHead()}.
- *
- * @param tag a tag for the delivery
- * @return a new Delivery object
- */
- public Delivery delivery(byte[] tag);
-
- /**
- * Create a delivery object based on the specified tag. This form
- * of the method is intended to allow the tag to be formed from a
- * subsequence of the byte array passed in. This might allow more
- * optimisation options in future but at present is not
- * implemented.
- *
- * @param tag a tag for the delivery
- * @param offset (currently ignored and must be 0)
- * @param length (currently ignored and must be the length of the <code>tag</code> array
- * @return a Delivery object
- */
- public Delivery delivery(byte[] tag, int offset, int length);
-
- /**
- * Returns the head delivery on the link.
- */
- Delivery head();
-
- /**
- * Returns the current delivery
- */
- Delivery current();
-
- /**
- * Attempts to advance the current delivery. Advances it to the next delivery if one exists, else null.
- *
- * The behaviour of this method is different for senders and receivers.
- *
- * @return true if it can advance, false if it cannot
- *
- * TODO document the meaning of the return value more fully. Currently Senderimpl only returns false if there is no current delivery
- */
- boolean advance();
-
-
- Source getSource();
- Target getTarget();
-
- /**
- * Sets the source for this link.
- *
- * The initiator of the link must always provide a Source.
- *
- * An application responding to the creation of the link should perform an application
- * specific lookup on the {@link #getRemoteSource()} to determine an actual Source. If it
- * failed to determine an actual source, it should set null, and then go on to {@link #close()}
- * the link.
- *
- * @see "AMQP Spec 1.0 section 2.6.3"
- */
- void setSource(Source address);
-
- /**
- * Expected to be used in a similar manner to {@link #setSource(Source)}
- */
- void setTarget(Target address);
-
- /**
- * @see #setSource(Source)
- */
- Source getRemoteSource();
-
- /**
- * @see #setTarget(Target)
- */
- Target getRemoteTarget();
-
- public Link next(EnumSet<EndpointState> local, EnumSet<EndpointState> remote);
-
- /**
- * Gets the credit balance for a link.
- *
- * Note that a sending link may still be used to send deliveries even if
- * link credit is/reaches zero, however those deliveries will end up being
- * {@link #getQueued() queued} by the link until enough credit is obtained
- * from the receiver to send them over the wire. In this case the balance
- * reported will go negative.
- *
- * @return the credit balance for the link
- */
- public int getCredit();
-
- /**
- * Gets the number of queued messages for a link.
- *
- * Links may queue deliveries for a number of reasons, for example there may be insufficient
- * {@link #getCredit() credit} to send them to the receiver, they may not have yet had a chance
- * to be written to the wire, or the receiving application has simply not yet processed them.
- *
- * @return the queued message count for the link
- */
- public int getQueued();
-
- public int getUnsettled();
-
- public Session getSession();
-
- SenderSettleMode getSenderSettleMode();
-
- /**
- * Sets the sender settle mode.
- *
- * Should only be called during link set-up, i.e. before calling {@link #open()}.
- *
- * If this endpoint is the initiator of the link, this method can be used to set a value other than
- * the default.
- *
- * If this endpoint is not the initiator, this method should be used to set a local value. According
- * to the AMQP spec, the application may choose to accept the sender's suggestion
- * (accessed by calling {@link #getRemoteSenderSettleMode()}) or choose another value. The value
- * has no effect on Proton, but may be useful to the application at a later point.
- *
- * In order to be AMQP compliant the application is responsible for honouring the settlement mode. See {@link Link}.
- */
- void setSenderSettleMode(SenderSettleMode senderSettleMode);
-
- /**
- * @see #setSenderSettleMode(SenderSettleMode)
- */
- SenderSettleMode getRemoteSenderSettleMode();
-
- ReceiverSettleMode getReceiverSettleMode();
-
- /**
- * Sets the receiver settle mode.
- *
- * Used in analogous way to {@link #setSenderSettleMode(SenderSettleMode)}
- */
- void setReceiverSettleMode(ReceiverSettleMode receiverSettleMode);
-
- /**
- * @see #setReceiverSettleMode(ReceiverSettleMode)
- */
- ReceiverSettleMode getRemoteReceiverSettleMode();
-
- /**
- * TODO should this be part of the interface?
- */
- @Deprecated
- void setRemoteSenderSettleMode(SenderSettleMode remoteSenderSettleMode);
-
- /**
- * Gets the local link properties.
- *
- * @see #setProperties(Map)
- */
- Map<Symbol, Object> getProperties();
-
- /**
- * Sets the local link properties, to be conveyed to the peer via the Attach frame when
- * attaching the link to the session.
- *
- * Must be called during link setup, i.e. before calling the {@link #open()} method.
- */
- void setProperties(Map<Symbol, Object> properties);
-
- /**
- * Gets the remote link properties, as conveyed from the peer via the Attach frame
- * when attaching the link to the session.
- *
- * @return the properties Map conveyed by the peer, or null if there was none.
- */
- Map<Symbol, Object> getRemoteProperties();
-
- public int drained();
-
- /**
- * Returns a [locally generated] view of credit at the remote peer by considering the
- * current link {@link #getCredit() credit} count as well as the effect of
- * any locally {@link #getQueued() queued} messages.
- *
- * @return view of effective remote credit
- */
- public int getRemoteCredit();
-
- public boolean getDrain();
-
- public void detach();
- public boolean detached();
-
- /**
- * Sets the local link offered capabilities, to be conveyed to the peer via the Attach frame
- * when attaching the link to the session.
- *
- * Must be called during link setup, i.e. before calling the {@link #open()} method.
- *
- * @param offeredCapabilities
- * the offered capabilities array to send, or null for none.
- */
- public void setOfferedCapabilities(Symbol[] offeredCapabilities);
-
- /**
- * Gets the local link offered capabilities.
- *
- * @return the offered capabilities array, or null if none was set.
- *
- * @see #setOfferedCapabilities(Symbol[])
- */
- Symbol[] getOfferedCapabilities();
-
- /**
- * Gets the remote link offered capabilities, as conveyed from the peer via the Attach frame
- * when attaching the link to the session.
- *
- * @return the offered capabilities array conveyed by the peer, or null if there was none.
- */
- Symbol[] getRemoteOfferedCapabilities();
-
- /**
- * Sets the local link desired capabilities, to be conveyed to the peer via the Attach frame
- * when attaching the link to the session.
- *
- * Must be called during link setup, i.e. before calling the {@link #open()} method.
- *
- * @param desiredCapabilities
- * the desired capabilities array to send, or null for none.
- */
- public void setDesiredCapabilities(Symbol[] desiredCapabilities);
-
- /**
- * Gets the local link desired capabilities.
- *
- * @return the desired capabilities array, or null if none was set.
- *
- * @see #setDesiredCapabilities(Symbol[])
- */
- Symbol[] getDesiredCapabilities();
-
- /**
- * Gets the remote link desired capabilities, as conveyed from the peer via the Attach frame
- * when attaching the link to the session.
- *
- * @return the desired capabilities array conveyed by the peer, or null if there was none.
- */
- Symbol[] getRemoteDesiredCapabilities();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJConnection.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJConnection.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJConnection.java
deleted file mode 100644
index bf44a3c..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJConnection.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.Connection;
-
-/**
- * Extends {@link Connection} with functionality that is specific to proton-j
- */
-public interface ProtonJConnection extends Connection, ProtonJEndpoint
-{
- void setLocalContainerId(String localContainerId);
-
- @Override
- ProtonJSession session();
-
- int getMaxChannels();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJEndpoint.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJEndpoint.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJEndpoint.java
deleted file mode 100644
index accc7e3..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJEndpoint.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.Endpoint;
-
-public interface ProtonJEndpoint extends Endpoint
-{
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSession.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSession.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSession.java
deleted file mode 100644
index f939d93..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSession.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.Sender;
-import org.apache.qpid.proton.engine.Session;
-
-/**
- * Extends {@link Session} with functionality that is specific to proton-j
- */
-public interface ProtonJSession extends Session, ProtonJEndpoint
-{
- Sender sender(String name);
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslDomain.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslDomain.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslDomain.java
deleted file mode 100644
index e1960fc..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslDomain.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.SslDomain;
-
-/**
- * Extends {@link SslDomain} with functionality that is specific to proton-j
- */
-public interface ProtonJSslDomain extends SslDomain
-{
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslPeerDetails.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslPeerDetails.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslPeerDetails.java
deleted file mode 100644
index ea5aae8..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJSslPeerDetails.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.SslPeerDetails;
-
-/**
- * Extends {@link SslPeerDetails} with functionality specific to proton-j
- */
-public interface ProtonJSslPeerDetails extends SslPeerDetails
-{
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJTransport.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJTransport.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJTransport.java
deleted file mode 100644
index 8bd24b3..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/ProtonJTransport.java
+++ /dev/null
@@ -1,32 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.Transport;
-import org.apache.qpid.proton.engine.impl.ProtocolTracer;
-
-/**
- * Extends {@link Transport} with functionality that is specific to proton-j
- */
-public interface ProtonJTransport extends Transport
-{
- void setProtocolTracer(ProtocolTracer protocolTracer);
-
- ProtocolTracer getProtocolTracer();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Receiver.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Receiver.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Receiver.java
deleted file mode 100644
index f9d718f..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Receiver.java
+++ /dev/null
@@ -1,86 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.codec.WritableBuffer;
-
-/**
- * Receiver
- *
- */
-public interface Receiver extends Link
-{
-
- /**
- * Adds the specified number of credits.
- *
- * The number of link credits initialises to zero. It is the application's responsibility to call
- * this method to allow the receiver to receive {@code credits} more deliveries.
- */
- public void flow(int credits);
-
- /**
- * Receive message data for the current delivery.
- *
- * If the caller takes all the bytes the Receiver currently has for this delivery then it is removed from
- * the Connection's work list.
- *
- * Before considering a delivery to be complete, the caller should examine {@link Delivery#isPartial()}. If
- * the delivery is partial, the caller should call {@link #recv(byte[], int, int)} again to receive
- * the additional bytes once the Delivery appears again on the Connection work-list.
- *
- * TODO might the flags other than IO_WORK in DeliveryImpl also prevent the work list being pruned?
- * e.g. what if a slow JMS consumer receives a disposition frame containing state=RELEASED? This is not IO_WORK.
- *
- * @param bytes the destination array where the message data is written
- * @param offset index in the array to start writing data at
- * @param size the maximum number of bytes to write
- *
- * @return number of bytes written. -1 if there are no more bytes for the current delivery.
- *
- * @see #current()
- */
- public int recv(byte[] bytes, int offset, int size);
-
- /**
- * Receive message data for the current delivery.
- *
- * @param buffer the buffer to write the message data.
- *
- * @return number of bytes written. -1 if there are no more bytes for the current delivery.
- */
- public int recv(WritableBuffer buffer);
-
- public void drain(int credit);
-
- /**
- * {@inheritDoc}
- *
- * TODO document what this method conceptually does and when you should use it.
- */
- @Override
- public boolean advance();
-
- public boolean draining();
-
- public void setDrain(boolean drain);
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Record.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Record.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Record.java
deleted file mode 100644
index e97948d..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Record.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-
-/**
- * Record
- *
- */
-
-public interface Record
-{
-
- <T> T get(Object key, Class<T> klass);
- <T> void set(Object key, Class<T> klass, T value);
- void clear();
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/RecordAccessor.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/RecordAccessor.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/RecordAccessor.java
deleted file mode 100644
index 4896b21..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/RecordAccessor.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-public interface RecordAccessor<T> {
- public T get(Record r);
- public void set(Record r, T value);
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Sasl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Sasl.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Sasl.java
deleted file mode 100644
index 08929e8..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Sasl.java
+++ /dev/null
@@ -1,180 +0,0 @@
-package org.apache.qpid.proton.engine;
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
-*/
-
-
-public interface Sasl
-{
- public enum SaslState
- {
- /** Pending configuration by application */
- PN_SASL_CONF,
- /** Pending SASL Init */
- PN_SASL_IDLE,
- /** negotiation in progress */
- PN_SASL_STEP,
- /** negotiation completed successfully */
- PN_SASL_PASS,
- /** negotiation failed */
- PN_SASL_FAIL
- }
-
- public enum SaslOutcome
- {
- /** negotiation not completed */
- PN_SASL_NONE((byte)-1),
- /** authentication succeeded */
- PN_SASL_OK((byte)0),
- /** failed due to bad credentials */
- PN_SASL_AUTH((byte)1),
- /** failed due to a system error */
- PN_SASL_SYS((byte)2),
- /** failed due to unrecoverable error */
- PN_SASL_PERM((byte)3),
- PN_SASL_TEMP((byte)4),
- PN_SASL_SKIPPED((byte)5);
-
- private final byte _code;
-
- /** failed due to transient error */
-
- SaslOutcome(byte code)
- {
- _code = code;
- }
-
- public byte getCode()
- {
- return _code;
- }
- }
-
- public static SaslOutcome PN_SASL_NONE = SaslOutcome.PN_SASL_NONE;
- public static SaslOutcome PN_SASL_OK = SaslOutcome.PN_SASL_OK;
- public static SaslOutcome PN_SASL_AUTH = SaslOutcome.PN_SASL_AUTH;
- public static SaslOutcome PN_SASL_SYS = SaslOutcome.PN_SASL_SYS;
- public static SaslOutcome PN_SASL_PERM = SaslOutcome.PN_SASL_PERM;
- public static SaslOutcome PN_SASL_TEMP = SaslOutcome.PN_SASL_TEMP;
- public static SaslOutcome PN_SASL_SKIPPED = SaslOutcome.PN_SASL_SKIPPED;
-
- /**
- * Access the current state of the layer.
- *
- * @return The state of the sasl layer.
- */
- SaslState getState();
-
- /**
- * Set the acceptable SASL mechanisms for the layer.
- *
- * @param mechanisms a list of acceptable SASL mechanisms
- */
- void setMechanisms(String... mechanisms);
-
- /**
- * Retrieve the list of SASL mechanisms provided by the remote.
- *
- * @return the SASL mechanisms advertised by the remote
- */
- String[] getRemoteMechanisms();
-
- /**
- * Set the remote hostname to indicate the host being connected to when
- * sending a SaslInit to the server.
- */
- void setRemoteHostname(String hostname);
-
- /**
- * Retrieve the hostname indicated by the client when sending its SaslInit.
- *
- * @return the hostname indicated by the remote client, or null if none specified.
- */
- String getHostname();
-
- /**
- * Determine the size of the bytes available via recv().
- *
- * Returns the size in bytes available via recv().
- *
- * @return The number of bytes available, zero if no available data.
- */
- int pending();
-
- /**
- * Read challenge/response data sent from the peer.
- *
- * Use pending to determine the size of the data.
- *
- * @param bytes written with up to size bytes of inbound data.
- * @param offset the offset in the array to begin writing at
- * @param size maximum number of bytes that bytes can accept.
- * @return The number of bytes written to bytes, or an error code if {@literal < 0}.
- */
- int recv(byte[] bytes, int offset, int size);
-
- /**
- * Send challenge or response data to the peer.
- *
- * @param bytes The challenge/response data.
- * @param offset the point within the array at which the data starts at
- * @param size The number of data octets in bytes.
- * @return The number of octets read from bytes, or an error code if {@literal < 0}
- */
- int send(byte[] bytes, int offset, int size);
-
-
- /**
- * Set the outcome of SASL negotiation
- *
- * Used by the server to set the result of the negotiation process.
- *
- * @param outcome the outcome of the SASL negotiation
- */
- void done(SaslOutcome outcome);
-
-
- /**
- * Configure the SASL layer to use the "PLAIN" mechanism.
- *
- * A utility function to configure a simple client SASL layer using
- * PLAIN authentication.
- *
- * @param username credential for the PLAIN authentication
- * mechanism
- * @param password credential for the PLAIN authentication
- * mechanism
- */
- void plain(String username, String password);
-
- /**
- * Retrieve the outcome of SASL negotiation.
- */
- SaslOutcome getOutcome();
-
- void client();
- void server();
-
- /**
- * Set whether servers may accept incoming connections
- * that skip the SASL layer negotiation.
- */
- void allowSkip(boolean allowSkip);
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Sender.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Sender.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Sender.java
deleted file mode 100644
index 159d5c3..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Sender.java
+++ /dev/null
@@ -1,87 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.codec.ReadableBuffer;
-
-/**
- * Sender
- *
- */
-public interface Sender extends Link
-{
-
- /**
- * indicates pending deliveries
- *
- * @param credits the number of pending deliveries
- */
- //TODO is this absolute or cumulative?
- public void offer(int credits);
-
- /**
- * Sends some data for the current delivery. The application may call this method multiple
- * times for the same delivery.
- *
- * @param bytes the byte array containing the data to be sent.
- * @param offset the offset into the given array to start reading.
- * @param length the number of bytes to read from the given byte array.
- *
- * @return the number of bytes accepted
- *
- * TODO Proton-j current copies all the bytes it has been given so the return value will always be
- * length. Should this be changed? How does Proton-c behave? What should the application do if
- * the number of bytes accepted is smaller than length.
- */
- public int send(byte[] bytes, int offset, int length);
-
- /**
- * Sends some data for the current delivery. The application may call this method multiple
- * times for the same delivery.
- *
- * @param buffer the buffer to read the data from.
- *
- * @return the number of bytes read from the provided buffer.
- */
- public int send(ReadableBuffer buffer);
-
- /**
- * Abort the current delivery.
- *
- * Note "pn_link_abort" is commented out in the .h
- */
- public void abort();
-
- /**
- * {@inheritDoc}
- *
- * Informs the sender that all the bytes of the current {@link Delivery} have been written.
- * The application must call this method in order for the delivery to be considered complete.
- *
- * @see #send(byte[], int, int)
- *
- * TODO fully state the rules regarding when you have to call this method, what happens if you don't call it
- * before creating another delivery etc.
- */
- @Override
- public boolean advance();
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Session.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Session.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Session.java
deleted file mode 100644
index 1a28c26..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Session.java
+++ /dev/null
@@ -1,150 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import java.util.EnumSet;
-import java.util.Map;
-
-import org.apache.qpid.proton.amqp.Symbol;
-
-
-/**
- * Session
- *
- * Note that session level flow control is handled internally by Proton.
- */
-public interface Session extends Endpoint
-{
- /**
- * Returns a newly created sender endpoint
- */
- public Sender sender(String name);
-
- /**
- * Returns a newly created receiver endpoint
- */
- public Receiver receiver(String name);
-
- public Session next(EnumSet<EndpointState> local, EnumSet<EndpointState> remote);
-
- public Connection getConnection();
-
- public int getIncomingCapacity();
-
- public void setIncomingCapacity(int bytes);
-
- public int getIncomingBytes();
-
- public int getOutgoingBytes();
-
- public long getOutgoingWindow();
-
- /**
- * Sets the outgoing window size.
- *
- * @param outgoingWindowSize the outgoing window size
- */
- public void setOutgoingWindow(long outgoingWindowSize);
-
- /**
- * Sets the local session properties, to be conveyed to the peer via the Begin frame when
- * attaching the session to the session.
- *
- * Must be called during session setup, i.e. before calling the {@link #open()} method.
- *
- * @param properties
- * the properties map to send, or null for none.
- */
- void setProperties(Map<Symbol, Object> properties);
-
- /**
- * Gets the local session properties.
- *
- * @return the properties map, or null if none was set.
- *
- * @see #setProperties(Map)
- */
- Map<Symbol, Object> getProperties();
-
- /**
- * Gets the remote session properties, as conveyed from the peer via the Begin frame
- * when opening the session.
- *
- * @return the properties Map conveyed by the peer, or null if there was none.
- */
- Map<Symbol, Object> getRemoteProperties();
-
- /**
- * Sets the local session offered capabilities, to be conveyed to the peer via the Begin frame
- * when opening the session.
- *
- * Must be called during session setup, i.e. before calling the {@link #open()} method.
- *
- * @param offeredCapabilities
- * the offered capabilities array to send, or null for none.
- */
- public void setOfferedCapabilities(Symbol[] offeredCapabilities);
-
- /**
- * Gets the local session offered capabilities.
- *
- * @return the offered capabilities array, or null if none was set.
- *
- * @see #setOfferedCapabilities(Symbol[])
- */
- Symbol[] getOfferedCapabilities();
-
- /**
- * Gets the remote session offered capabilities, as conveyed from the peer via the Begin frame
- * when opening the session.
- *
- * @return the offered capabilities array conveyed by the peer, or null if there was none.
- */
- Symbol[] getRemoteOfferedCapabilities();
-
- /**
- * Sets the local session desired capabilities, to be conveyed to the peer via the Begin frame
- * when opening the session.
- *
- * Must be called during session setup, i.e. before calling the {@link #open()} method.
- *
- * @param desiredCapabilities
- * the desired capabilities array to send, or null for none.
- */
- public void setDesiredCapabilities(Symbol[] desiredCapabilities);
-
- /**
- * Gets the local session desired capabilities.
- *
- * @return the desired capabilities array, or null if none was set.
- *
- * @see #setDesiredCapabilities(Symbol[])
- */
- Symbol[] getDesiredCapabilities();
-
- /**
- * Gets the remote session desired capabilities, as conveyed from the peer via the Begin frame
- * when opening the session.
- *
- * @return the desired capabilities array conveyed by the peer, or null if there was none.
- */
- Symbol[] getRemoteDesiredCapabilities();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Ssl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Ssl.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Ssl.java
deleted file mode 100644
index 8d3bab7..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Ssl.java
+++ /dev/null
@@ -1,51 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-/**
- * I represent the details of a particular SSL session.
- */
-public interface Ssl
-{
- /**
- * Get the name of the Cipher that is currently in use.
- *
- * Gets a text description of the cipher that is currently active, or returns null if SSL
- * is not active (no cipher). Note that the cipher in use may change over time due to
- * renegotiation or other changes to the SSL state.
- *
- * @return the name of the cipher in use, or null if none
- */
- String getCipherName();
-
- /**
- * Get the name of the SSL protocol that is currently in use.
- *
- * Gets a text description of the SSL protocol that is currently active, or null if SSL
- * is not active. Note that the protocol may change over time due to renegotiation.
- *
- * @return the name of the protocol in use, or null if none
- */
- String getProtocolName();
-
- void setPeerHostname(String hostname);
-
- String getPeerHostname();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/SslDomain.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/SslDomain.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/SslDomain.java
deleted file mode 100644
index 24b101c..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/SslDomain.java
+++ /dev/null
@@ -1,145 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.impl.ssl.SslDomainImpl;
-
-/**
- * I store the details used to create SSL sessions.
- */
-public interface SslDomain
-{
-
- public static final class Factory
- {
- public static SslDomain create() {
- return new SslDomainImpl();
- }
- }
-
- /**
- * Determines whether the endpoint acts as a client or server.
- */
- public enum Mode
- {
- /** Local connection endpoint is an SSL client */
- CLIENT,
-
- /** Local connection endpoint is an SSL server */
- SERVER
- }
-
- /**
- * Determines the level of peer validation.
- *
- * {@link #ANONYMOUS_PEER} is configured by default.
- */
- public enum VerifyMode
- {
- /**
- * will only connect to those peers that provide a valid identifying certificate signed
- * by a trusted CA and are using an authenticated cipher
- */
- VERIFY_PEER,
- VERIFY_PEER_NAME,
- /**
- * does not require a valid certificate, and permits use of ciphers that
- * do not provide authentication
- */
- ANONYMOUS_PEER,
- }
-
- /**
- * Initialize the ssl domain object.
- *
- * An SSL object be either an SSL server or an SSL client. It cannot be both. Those
- * transports that will be used to accept incoming connection requests must be configured
- * as an SSL server. Those transports that will be used to initiate outbound connections
- * must be configured as an SSL client.
- *
- */
- void init(Mode mode);
-
- Mode getMode();
-
- /**
- * Set the certificate that identifies the local node to the remote.
- *
- * This certificate establishes the identity for the local node. It will be sent to the
- * remote if the remote needs to verify the identity of this node. This may be used for
- * both SSL servers and SSL clients (if client authentication is required by the server).
- *
- * @param certificateFile path to file/database containing the identifying
- * certificate.
- * @param privateKeyFile path to file/database containing the private key used to
- * sign the certificate
- * @param password the password used to sign the key, else null if key is not
- * protected.
- */
- void setCredentials(String certificateFile, String privateKeyFile, String password);
-
- String getPrivateKeyFile();
-
- String getPrivateKeyPassword();
-
- String getCertificateFile();
-
- /**
- * Configure the set of trusted CA certificates used by this node to verify peers.
- *
- * If the local SSL client/server needs to verify the identity of the remote, it must
- * validate the signature of the remote's certificate. This function sets the database of
- * trusted CAs that will be used to verify the signature of the remote's certificate.
- *
- * @param certificateDb database of trusted CAs, used to authenticate the peer.
- */
- void setTrustedCaDb(String certificateDb);
-
- String getTrustedCaDb();
-
- /**
- * Configure the level of verification used on the peer certificate.
- *
- * This method controls how the peer's certificate is validated, if at all. By default,
- * neither servers nor clients attempt to verify their peers ({@link VerifyMode#ANONYMOUS_PEER}).
- * Once certificates and trusted CAs are configured, peer verification can be enabled.
- *
- * In order to verify a peer, a trusted CA must be configured. See
- * {@link #setTrustedCaDb(String)}.
- *
- * NOTE: Servers must provide their own certificate when verifying a peer. See
- * {@link #setCredentials(String, String, String)}).
- *
- * @param mode the level of validation to apply to the peer
- */
- void setPeerAuthentication(VerifyMode mode);
-
- VerifyMode getPeerAuthentication();
-
- /**
- * Permit a server to accept connection requests from non-SSL clients.
- *
- * This configures the server to "sniff" the incoming client data stream, and dynamically
- * determine whether SSL/TLS is being used. This option is disabled by default: only
- * clients using SSL/TLS are accepted.
- */
- void allowUnsecuredClient(boolean allowUnsecured);
-
- boolean allowUnsecuredClient();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/SslPeerDetails.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/SslPeerDetails.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/SslPeerDetails.java
deleted file mode 100644
index 5b318fe..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/SslPeerDetails.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton.engine;
-
-import org.apache.qpid.proton.engine.impl.ssl.SslPeerDetailsImpl;
-
-/**
- * The details of the remote peer involved in an SSL session.
- *
- * Used when creating an SSL session to hint that the underlying SSL implementation
- * should attempt to resume a previous session if one exists for the same peer details,
- * e.g. using session identifiers (http://tools.ietf.org/html/rfc5246) or session tickets
- * (http://tools.ietf.org/html/rfc5077).
- */
-public interface SslPeerDetails
-{
-
- public static final class Factory
- {
- public static SslPeerDetails create(String hostname, int port) {
- return new SslPeerDetailsImpl(hostname, port);
- }
- }
-
- String getHostname();
- int getPort();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/Transport.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Transport.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Transport.java
deleted file mode 100644
index 5d8b79d..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Transport.java
+++ /dev/null
@@ -1,285 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-import java.nio.ByteBuffer;
-
-import org.apache.qpid.proton.amqp.transport.ErrorCondition;
-import org.apache.qpid.proton.engine.impl.TransportImpl;
-
-
-/**
- * <p>
- * Operates on the entities in the associated {@link Connection}
- * by accepting and producing binary AMQP output, potentially
- * layered within SASL and/or SSL.
- * </p>
- * <p>
- * After a connection is bound with {@link #bind(Connection)}, the methods for accepting and producing
- * output are typically repeatedly called. See the specific methods for details of their legal usage.
- * </p>
- * <p>
- * <strong>Processing the input data received from another AMQP container.</strong>
- * </p>
- * <ol>
- * <li>{@link #getInputBuffer()} </li>
- * <li>Write data into input buffer</li>
- * <li>{@link #processInput()}</li>
- * <li>Check the result, e.g. by calling {@link TransportResult#checkIsOk()}</li>
- * </ol>
- * <p>
- * <strong>Getting the output data to send to another AMQP container:</strong>
- * </p>
- * <ol>
- * <li>{@link #getOutputBuffer()} </li>
- * <li>Read output from output buffer</li>
- * <li>{@link #outputConsumed()}</li>
- * </ol>
- *
- * <p>The following methods on the byte buffers returned by {@link #getInputBuffer()} and {@link #getOutputBuffer()}
- * must not be called:
- * </p>
- * <ol>
- * <li> {@link ByteBuffer#clear()} </li>
- * <li> {@link ByteBuffer#compact()} </li>
- * <li> {@link ByteBuffer#flip()} </li>
- * <li> {@link ByteBuffer#mark()} </li>
- * </ol>
- */
-public interface Transport extends Endpoint
-{
-
- public static final class Factory
- {
- public static Transport create() {
- return new TransportImpl();
- }
- }
-
- public static final int TRACE_OFF = 0;
- public static final int TRACE_RAW = 1;
- public static final int TRACE_FRM = 2;
- public static final int TRACE_DRV = 4;
-
- public static final int DEFAULT_MAX_FRAME_SIZE = -1;
-
- /** the lower bound for the agreed maximum frame size (in bytes). */
- public int MIN_MAX_FRAME_SIZE = 512;
- public int SESSION_WINDOW = 16*1024;
- public int END_OF_STREAM = -1;
-
- public void trace(int levels);
-
- public void bind(Connection connection);
- public void unbind();
-
- public int capacity();
- public ByteBuffer tail();
- public void process() throws TransportException;
- public void close_tail();
-
-
- public int pending();
- public ByteBuffer head();
- public void pop(int bytes);
- public void close_head();
-
- public boolean isClosed();
-
- /**
- * Processes the provided input.
- *
- * @param bytes input bytes for consumption
- * @param offset the offset within bytes where input begins
- * @param size the number of bytes available for input
- *
- * @return the number of bytes consumed
- * @throws TransportException if the input is invalid, if the transport is already in an error state,
- * or if the input is empty (unless the remote connection is already closed)
- * @deprecated use {@link #getInputBuffer()} and {@link #processInput()} instead.
- */
- @Deprecated
- public int input(byte[] bytes, int offset, int size);
-
- /**
- * Get a buffer that can be used to write input data into the transport.
- * Once the client has finished putting into the input buffer, {@link #processInput()}
- * must be called.
- *
- * Successive calls to this method are not guaranteed to return the same object.
- * Once {@link #processInput()} is called the buffer must not be used.
- *
- * @throws TransportException if the transport is already in an invalid state
- */
- ByteBuffer getInputBuffer();
-
- /**
- * Tell the transport to process the data written to the input buffer.
- *
- * If the returned result indicates failure, the transport will not accept any more input.
- * Specifically, any subsequent {@link #processInput()} calls on this object will
- * throw an exception.
- *
- * @return the result of processing the data, which indicates success or failure.
- * @see #getInputBuffer()
- */
- TransportResult processInput();
-
- /**
- * Has the transport produce up to size bytes placing the result
- * into dest beginning at position offset.
- *
- * @param dest array for output bytes
- * @param offset the offset within bytes where output begins
- * @param size the maximum number of bytes to be output
- *
- * @return the number of bytes written
- * @deprecated use {@link #getOutputBuffer()} and {@link #outputConsumed()} instead
- */
- @Deprecated
- public int output(byte[] dest, int offset, int size);
-
- /**
- * Get a read-only byte buffer containing the transport's pending output.
- * Once the client has finished getting from the output buffer, {@link #outputConsumed()}
- * must be called.
- *
- * Successive calls to this method are not guaranteed to return the same object.
- * Once {@link #outputConsumed()} is called the buffer must not be used.
- *
- * If the transport's state changes AFTER calling this method, this will not be
- * reflected in the output buffer.
- */
- ByteBuffer getOutputBuffer();
-
- /**
- * Informs the transport that the output buffer returned by {@link #getOutputBuffer()}
- * is finished with, allowing implementation-dependent steps to be performed such as
- * reclaiming buffer space.
- */
- void outputConsumed();
-
- /**
- * Signal the transport to expect SASL frames used to establish a SASL layer prior to
- * performing the AMQP protocol version negotiation. This must first be performed before
- * the transport is used for processing. Subsequent invocations will return the same
- * {@link Sasl} object.
- *
- * @throws IllegalStateException if transport processing has already begun prior to initial invocation
- */
- Sasl sasl() throws IllegalStateException;
-
- /**
- * Wrap this transport's output and input to apply SSL encryption and decryption respectively.
- *
- * This method is expected to be called at most once. A subsequent invocation will return the same
- * {@link Ssl} object, regardless of the parameters supplied.
- *
- * @param sslDomain the SSL settings to use
- * @param sslPeerDetails may be null, in which case SSL session resume will not be attempted
- * @return an {@link Ssl} object representing the SSL session.
- */
- Ssl ssl(SslDomain sslDomain, SslPeerDetails sslPeerDetails);
-
- /**
- * As per {@link #ssl(SslDomain, SslPeerDetails)} but no attempt is made to resume a previous SSL session.
- */
- Ssl ssl(SslDomain sslDomain);
-
-
- /**
- * Get the maximum frame size for the transport
- *
- * @return the maximum frame size
- */
- int getMaxFrameSize();
-
- void setMaxFrameSize(int size);
-
- int getRemoteMaxFrameSize();
-
- /**
- * Gets the local channel-max value to be advertised to the remote peer
- *
- * @return the local channel-max value
- * @see #setChannelMax(int)
- */
- int getChannelMax();
-
- /**
- * Set the local value of channel-max, to be advertised to the peer on the
- * <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-transport-v1.0-os.html#type-open">
- * Open frame</a> emitted by the transport.
- *
- * The remote peers advertised channel-max can be observed using {@link #getRemoteChannelMax()}.
- *
- * @param channelMax the local channel-max to advertise to the peer, in range [0 - 2^16).
- * @throws IllegalArgumentException if the value supplied is outside range [0 - 2^16).
- */
- void setChannelMax(int channelMax);
-
- /**
- * Gets the remote value of channel-max, as advertised by the peer on its
- * <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-transport-v1.0-os.html#type-open">
- * Open frame</a>.
- *
- * The local peers advertised channel-max can be observed using {@link #getChannelMax()}.
- *
- * @return the remote channel-max value
- */
- int getRemoteChannelMax();
-
- ErrorCondition getCondition();
-
- /**
- *
- * @param timeout local idle timeout in milliseconds
- */
- void setIdleTimeout(int timeout);
- /**
- *
- * @return local idle timeout in milliseconds
- */
- int getIdleTimeout();
- /**
- *
- * @return remote idle timeout in milliseconds
- */
- int getRemoteIdleTimeout();
-
- long tick(long now);
-
- long getFramesInput();
-
- long getFramesOutput();
-
- /**
- * Configure whether a synthetic Flow event should be emitted when messages are sent,
- * reflecting a change in the credit level on the link that may prompt other action.
- *
- * Defaults to true.
- *
- * @param emitFlowEventOnSend true if a flow event should be emitted, false otherwise
- */
- void setEmitFlowEventOnSend(boolean emitFlowEventOnSend);
-
- boolean isEmitFlowEventOnSend();
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportException.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportException.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportException.java
deleted file mode 100644
index c4955b4..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportException.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.proton.engine;
-
-import java.util.IllegalFormatException;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.apache.qpid.proton.ProtonException;
-
-public class TransportException extends ProtonException
-{
-
- private static final Logger LOGGER = Logger.getLogger(TransportException.class.getName());
-
- public TransportException()
- {
- }
-
- public TransportException(String message)
- {
- super(message);
- }
-
- public TransportException(String message, Throwable cause)
- {
- super(message, cause);
- }
-
- public TransportException(Throwable cause)
- {
- super(cause);
- }
-
- private static String format(String format, Object ... args)
- {
- try
- {
- return String.format(format, args);
- }
- catch(IllegalFormatException e)
- {
- LOGGER.log(Level.SEVERE, "Formating error in string " + format, e);
- return format;
- }
- }
-
- public TransportException(String format, Object ... args)
- {
- this(format(format, args));
- }
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportResult.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportResult.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportResult.java
deleted file mode 100644
index a484ce7..0000000
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/TransportResult.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton.engine;
-
-public interface TransportResult
-{
- enum Status
- {
- OK,
- ERROR
- }
-
- Status getStatus();
-
- String getErrorDescription();
-
- Exception getException();
-
- /**
- * @throws TransportException if the result's state is not ok.
- */
- void checkIsOk();
-
- boolean isOk();
-
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org