http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/cf29c4ae/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportSession.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportSession.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportSession.java index 1f4a9f8..79d953b 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportSession.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportSession.java @@ -31,12 +31,13 @@ import org.apache.qpid.proton.amqp.transport.Flow; import org.apache.qpid.proton.amqp.transport.Role; import org.apache.qpid.proton.amqp.transport.Transfer; import org.apache.qpid.proton.engine.Event; +import org.apache.qpid.proton.engine.Transport; class TransportSession { private static final int HANDLE_MAX = 65535; - private final TransportImpl _transport; + private final Transport _transport; private final SessionImpl _session; private int _localChannel = -1; private int _remoteChannel = -1; @@ -66,7 +67,7 @@ class TransportSession private boolean _endReceived; private boolean _beginSent; - TransportSession(TransportImpl transport, SessionImpl session) + TransportSession(Transport transport, SessionImpl session) { _transport = transport; _session = session;
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/cf29c4ae/proton-j/src/main/java/org/apache/qpid/proton/framing/TransportFrame2.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/framing/TransportFrame2.java b/proton-j/src/main/java/org/apache/qpid/proton/framing/TransportFrame2.java new file mode 100644 index 0000000..cea799b --- /dev/null +++ b/proton-j/src/main/java/org/apache/qpid/proton/framing/TransportFrame2.java @@ -0,0 +1,63 @@ +/* + * + * 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.framing; + +import org.apache.qpid.proton.transport2.Performative; + +public class TransportFrame2 +{ + private final int _channel; + + private final Performative _performative; + + private final byte[] _payload; + + public TransportFrame2(final int channel, final Performative performative, final byte[] payload) + { + _payload = payload; + _performative = performative; + _channel = channel; + } + + public int getChannel() + { + return _channel; + } + + public Performative getPerformative() + { + return _performative; + } + + public byte[] getPayload() + { + return _payload; + } + + @Override + public String toString() + { + StringBuilder builder = new StringBuilder(); + builder.append("TransportFrame{ _channel=").append(_channel).append(", _performative=").append(_performative) + .append("}"); + return builder.toString(); + } +} \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
