You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2015/08/14 21:07:52 UTC
[19/50] [abbrv] qpid-proton git commit: Added the attribute factory
to reference the Factory that creates the respective object based on an
object passed in.
Added the attribute factory to reference the Factory that creates the respective object based on an object passed in.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/a9265cfb
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/a9265cfb
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/a9265cfb
Branch: refs/heads/rajith-codec
Commit: a9265cfbdacc37951bbfa7b4de4699d3e3ed6bd1
Parents: dfea230
Author: Rajith Attapattu <ra...@apache.org>
Authored: Mon May 4 13:20:32 2015 -0400
Committer: Rajith Attapattu <ra...@apache.org>
Committed: Thu Jul 9 09:12:38 2015 -0400
----------------------------------------------------------------------
.../apache/qpid/proton/transport/Attach.java | 34 +++++++++++---------
.../org/apache/qpid/proton/transport/Begin.java | 20 ++++++------
.../org/apache/qpid/proton/transport/Close.java | 2 ++
.../apache/qpid/proton/transport/Detach.java | 2 ++
.../qpid/proton/transport/Disposition.java | 16 +++++----
.../org/apache/qpid/proton/transport/End.java | 2 ++
.../qpid/proton/transport/ErrorCondition.java | 2 ++
.../org/apache/qpid/proton/transport/Flow.java | 28 ++++++++--------
.../org/apache/qpid/proton/transport/Open.java | 24 +++++++-------
.../apache/qpid/proton/transport/Transfer.java | 26 ++++++++-------
10 files changed, 88 insertions(+), 68 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Attach.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Attach.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Attach.java
index 0756eb8..f2fbf08 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Attach.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Attach.java
@@ -37,6 +37,8 @@ public final class Attach implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:attach:list";
+ public final static Factory FACTORY = new Factory();
+
private String _name;
private int _handle;
@@ -302,7 +304,7 @@ public final class Attach implements Encodable
: ReceiverSettleMode.values()[(Integer) l.get(4)]);
case 10:
attach.setSndSettleMode(l.get(3) == null ? SenderSettleMode.MIXED : SenderSettleMode.values()[(Integer) l
- .get(3)]);
+ .get(3)]);
case 11:
attach.setRole(Boolean.TRUE.equals(l.get(2)) ? Role.RECEIVER : Role.SENDER);
case 12:
@@ -319,20 +321,20 @@ public final class Attach implements Encodable
public String toString()
{
return "Attach{" +
- "name='" + _name + '\'' +
- ", handle=" + _handle +
- ", role=" + _role +
- ", sndSettleMode=" + _sndSettleMode +
- ", rcvSettleMode=" + _rcvSettleMode +
- ", source=" + _source +
- ", target=" + _target +
- ", unsettled=" + _unsettled +
- ", incompleteUnsettled=" + _incompleteUnsettled +
- ", initialDeliveryCount=" + _initialDeliveryCount +
- ", maxMessageSize=" + _maxMessageSize +
- ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) +
- ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) +
- ", properties=" + _properties +
- '}';
+ "name='" + _name + '\'' +
+ ", handle=" + _handle +
+ ", role=" + _role +
+ ", sndSettleMode=" + _sndSettleMode +
+ ", rcvSettleMode=" + _rcvSettleMode +
+ ", source=" + _source +
+ ", target=" + _target +
+ ", unsettled=" + _unsettled +
+ ", incompleteUnsettled=" + _incompleteUnsettled +
+ ", initialDeliveryCount=" + _initialDeliveryCount +
+ ", maxMessageSize=" + _maxMessageSize +
+ ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) +
+ ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) +
+ ", properties=" + _properties +
+ '}';
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Begin.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Begin.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Begin.java
index 4806b58..469651e 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Begin.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Begin.java
@@ -37,6 +37,8 @@ public final class Begin implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:begin:list";
+ public final static Factory FACTORY = new Factory();
+
private int _remoteChannel;
private int _nextOutgoingId;
@@ -203,14 +205,14 @@ public final class Begin implements Encodable
public String toString()
{
return "Begin{" +
- "remoteChannel=" + _remoteChannel +
- ", nextOutgoingId=" + _nextOutgoingId +
- ", incomingWindow=" + _incomingWindow +
- ", outgoingWindow=" + _outgoingWindow +
- ", handleMax=" + _handleMax +
- ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) +
- ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) +
- ", properties=" + _properties +
- '}';
+ "remoteChannel=" + _remoteChannel +
+ ", nextOutgoingId=" + _nextOutgoingId +
+ ", incomingWindow=" + _incomingWindow +
+ ", outgoingWindow=" + _outgoingWindow +
+ ", handleMax=" + _handleMax +
+ ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) +
+ ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) +
+ ", properties=" + _properties +
+ '}';
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Close.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Close.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Close.java
index e9ef2df..b642fe5 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Close.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Close.java
@@ -34,6 +34,8 @@ public final class Close implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:close:list";
+ public final static Factory FACTORY = new Factory();
+
private ErrorCondition _error;
public ErrorCondition getError()
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Detach.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Detach.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Detach.java
index fbe7d17..835c0d9 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Detach.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Detach.java
@@ -34,6 +34,8 @@ public final class Detach implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:detach:list";
+ public final static Factory FACTORY = new Factory();
+
private int _handle;
private boolean _closed;
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Disposition.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Disposition.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Disposition.java
index 441b005..10198c7 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Disposition.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Disposition.java
@@ -34,6 +34,8 @@ public final class Disposition implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:disposition:list";
+ public final static Factory FACTORY = new Factory();
+
private Role _role = Role.SENDER;
private int _first;
@@ -168,12 +170,12 @@ public final class Disposition implements Encodable
public String toString()
{
return "Disposition{" +
- "role=" + _role +
- ", first=" + _first +
- ", last=" + _last +
- ", settled=" + _settled +
- ", state=" + _state +
- ", batchable=" + _batchable +
- '}';
+ "role=" + _role +
+ ", first=" + _first +
+ ", last=" + _last +
+ ", settled=" + _settled +
+ ", state=" + _state +
+ ", batchable=" + _batchable +
+ '}';
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/End.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/End.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/End.java
index e655f52..fbb7ef2 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/End.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/End.java
@@ -34,6 +34,8 @@ public final class End implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:end:list";
+ public final static Factory FACTORY = new Factory();
+
private ErrorCondition _error;
public ErrorCondition getError()
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/ErrorCondition.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/ErrorCondition.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/ErrorCondition.java
index bb8f062..ffd5a09 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/ErrorCondition.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/ErrorCondition.java
@@ -36,6 +36,8 @@ public final class ErrorCondition implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:error:list";
+ public final static Factory FACTORY = new Factory();
+
private String _condition;
private String _description;
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Flow.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Flow.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Flow.java
index 1e01b61..e6aee5c 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Flow.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Flow.java
@@ -26,9 +26,9 @@ import java.util.Map;
import org.apache.qpid.proton.codec2.CodecHelper;
import org.apache.qpid.proton.codec2.DecodeException;
+import org.apache.qpid.proton.codec2.DescribedTypeFactory;
import org.apache.qpid.proton.codec2.Encodable;
import org.apache.qpid.proton.codec2.Encoder;
-import org.apache.qpid.proton.codec2.DescribedTypeFactory;
public final class Flow implements Encodable
{
@@ -36,6 +36,8 @@ public final class Flow implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:flow:list";
+ public final static Factory FACTORY = new Factory();
+
private int _nextIncomingId;
private int _incomingWindow;
@@ -232,17 +234,17 @@ public final class Flow implements Encodable
public String toString()
{
return "Flow{" +
- "nextIncomingId=" + _nextIncomingId +
- ", incomingWindow=" + _incomingWindow +
- ", nextOutgoingId=" + _nextOutgoingId +
- ", outgoingWindow=" + _outgoingWindow +
- ", handle=" + _handle +
- ", deliveryCount=" + _deliveryCount +
- ", linkCredit=" + _linkCredit +
- ", available=" + _available +
- ", drain=" + _drain +
- ", echo=" + _echo +
- ", properties=" + _properties +
- '}';
+ "nextIncomingId=" + _nextIncomingId +
+ ", incomingWindow=" + _incomingWindow +
+ ", nextOutgoingId=" + _nextOutgoingId +
+ ", outgoingWindow=" + _outgoingWindow +
+ ", handle=" + _handle +
+ ", deliveryCount=" + _deliveryCount +
+ ", linkCredit=" + _linkCredit +
+ ", available=" + _available +
+ ", drain=" + _drain +
+ ", echo=" + _echo +
+ ", properties=" + _properties +
+ '}';
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Open.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Open.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Open.java
index 5496eda..d870dea 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Open.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Open.java
@@ -37,6 +37,8 @@ public final class Open implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:open:list";
+ public final static Factory FACTORY = new Factory();
+
private String _containerId;
private String _hostname;
@@ -253,16 +255,16 @@ public final class Open implements Encodable
public String toString()
{
return "Open{" +
- " containerId='" + _containerId + '\'' +
- ", hostname='" + _hostname + '\'' +
- ", maxFrameSize=" + _maxFrameSize +
- ", channelMax=" + _channelMax +
- ", idleTimeOut=" + _idleTimeOut +
- ", outgoingLocales=" + (_outgoingLocales == null ? null : Arrays.asList(_outgoingLocales)) +
- ", incomingLocales=" + (_incomingLocales == null ? null : Arrays.asList(_incomingLocales)) +
- ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) +
- ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) +
- ", properties=" + _properties +
- '}';
+ " containerId='" + _containerId + '\'' +
+ ", hostname='" + _hostname + '\'' +
+ ", maxFrameSize=" + _maxFrameSize +
+ ", channelMax=" + _channelMax +
+ ", idleTimeOut=" + _idleTimeOut +
+ ", outgoingLocales=" + (_outgoingLocales == null ? null : Arrays.asList(_outgoingLocales)) +
+ ", incomingLocales=" + (_incomingLocales == null ? null : Arrays.asList(_incomingLocales)) +
+ ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) +
+ ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) +
+ ", properties=" + _properties +
+ '}';
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a9265cfb/proton-j/src/main/java/org/apache/qpid/proton/transport/Transfer.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport/Transfer.java b/proton-j/src/main/java/org/apache/qpid/proton/transport/Transfer.java
index 42f38be..1723782 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport/Transfer.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport/Transfer.java
@@ -34,6 +34,8 @@ public final class Transfer implements Encodable
public final static String DESCRIPTOR_STRING = "amqp:transfer:list";
+ public final static Factory FACTORY = new Factory();
+
private int _handle;
private int _deliveryId;
@@ -235,17 +237,17 @@ public final class Transfer implements Encodable
public String toString()
{
return "Transfer{" +
- "handle=" + _handle +
- ", deliveryId=" + _deliveryId +
- ", deliveryTag=" + _deliveryTag +
- ", messageFormat=" + _messageFormat +
- ", settled=" + _settled +
- ", more=" + _more +
- ", rcvSettleMode=" + _rcvSettleMode +
- ", state=" + _state +
- ", resume=" + _resume +
- ", aborted=" + _aborted +
- ", batchable=" + _batchable +
- '}';
+ "handle=" + _handle +
+ ", deliveryId=" + _deliveryId +
+ ", deliveryTag=" + _deliveryTag +
+ ", messageFormat=" + _messageFormat +
+ ", settled=" + _settled +
+ ", more=" + _more +
+ ", rcvSettleMode=" + _rcvSettleMode +
+ ", state=" + _state +
+ ", resume=" + _resume +
+ ", aborted=" + _aborted +
+ ", batchable=" + _batchable +
+ '}';
}
}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org