You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/10/16 20:48:05 UTC
svn commit: r464620 [3/6] - in /incubator/activemq/sandbox/qpid:
src/main/java/org/apache/activemq/qpid/command/
src/main/java/org/apache/activemq/qpid/transport/
src/main/java/org/apache/activemq/qpid/wireformat/
src/main/java/org/apache/activemq/qpid...
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -45,7 +45,55 @@
public String routingKey;
public boolean nowait;
public FieldTable arguments;
-
+
+ public void setTicket(int ticket) {
+ this.ticket = ticket;
+ }
+ public int getTicket() {
+ return this.ticket;
+ }
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+ public void setExchange(String exchange) {
+ this.exchange = exchange;
+ }
+ public String getExchange() {
+ return this.exchange;
+ }
+
+ public void setRoutingKey(String routingKey) {
+ this.routingKey = routingKey;
+ }
+ public String getRoutingKey() {
+ return this.routingKey;
+ }
+
+ public void setNowait(boolean nowait) {
+ this.nowait = nowait;
+ }
+ public boolean getNowait() {
+ return this.nowait;
+ }
+
+ public void setArguments(FieldTable arguments) {
+ this.arguments = arguments;
+ }
+ public FieldTable getArguments() {
+ return this.arguments;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueueBindBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueueBindOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -47,7 +47,69 @@
public boolean autoDelete;
public boolean nowait;
public FieldTable arguments;
-
+
+ public void setTicket(int ticket) {
+ this.ticket = ticket;
+ }
+ public int getTicket() {
+ return this.ticket;
+ }
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+ public void setPassive(boolean passive) {
+ this.passive = passive;
+ }
+ public boolean getPassive() {
+ return this.passive;
+ }
+
+ public void setDurable(boolean durable) {
+ this.durable = durable;
+ }
+ public boolean getDurable() {
+ return this.durable;
+ }
+
+ public void setExclusive(boolean exclusive) {
+ this.exclusive = exclusive;
+ }
+ public boolean getExclusive() {
+ return this.exclusive;
+ }
+
+ public void setAutoDelete(boolean autoDelete) {
+ this.autoDelete = autoDelete;
+ }
+ public boolean getAutoDelete() {
+ return this.autoDelete;
+ }
+
+ public void setNowait(boolean nowait) {
+ this.nowait = nowait;
+ }
+ public boolean getNowait() {
+ return this.nowait;
+ }
+
+ public void setArguments(FieldTable arguments) {
+ this.arguments = arguments;
+ }
+ public FieldTable getArguments() {
+ return this.arguments;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueueDeclareBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -42,7 +42,34 @@
public String queue;
public long messageCount;
public long consumerCount;
-
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+ public void setMessageCount(long messageCount) {
+ this.messageCount = messageCount;
+ }
+ public long getMessageCount() {
+ return this.messageCount;
+ }
+
+ public void setConsumerCount(long consumerCount) {
+ this.consumerCount = consumerCount;
+ }
+ public long getConsumerCount() {
+ return this.consumerCount;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueueDeclareOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -44,7 +44,48 @@
public boolean ifUnused;
public boolean ifEmpty;
public boolean nowait;
-
+
+ public void setTicket(int ticket) {
+ this.ticket = ticket;
+ }
+ public int getTicket() {
+ return this.ticket;
+ }
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+ public void setIfUnused(boolean ifUnused) {
+ this.ifUnused = ifUnused;
+ }
+ public boolean getIfUnused() {
+ return this.ifUnused;
+ }
+
+ public void setIfEmpty(boolean ifEmpty) {
+ this.ifEmpty = ifEmpty;
+ }
+ public boolean getIfEmpty() {
+ return this.ifEmpty;
+ }
+
+ public void setNowait(boolean nowait) {
+ this.nowait = nowait;
+ }
+ public boolean getNowait() {
+ return this.nowait;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueueDeleteBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public long messageCount;
-
+
+ public void setMessageCount(long messageCount) {
+ this.messageCount = messageCount;
+ }
+ public long getMessageCount() {
+ return this.messageCount;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueueDeleteOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -42,7 +42,34 @@
public int ticket;
public String queue;
public boolean nowait;
-
+
+ public void setTicket(int ticket) {
+ this.ticket = ticket;
+ }
+ public int getTicket() {
+ return this.ticket;
+ }
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+ public void setNowait(boolean nowait) {
+ this.nowait = nowait;
+ }
+ public boolean getNowait() {
+ return this.nowait;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueuePurgeBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public long messageCount;
-
+
+ public void setMessageCount(long messageCount) {
+ this.messageCount = messageCount;
+ }
+ public long getMessageCount() {
+ return this.messageCount;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processQueuePurgeOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -41,7 +41,27 @@
public String consumerTag;
public boolean nowait;
-
+
+ public void setConsumerTag(String consumerTag) {
+ this.consumerTag = consumerTag;
+ }
+ public String getConsumerTag() {
+ return this.consumerTag;
+ }
+
+ public void setNowait(boolean nowait) {
+ this.nowait = nowait;
+ }
+ public boolean getNowait() {
+ return this.nowait;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamCancelBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public String consumerTag;
-
+
+ public void setConsumerTag(String consumerTag) {
+ this.consumerTag = consumerTag;
+ }
+ public String getConsumerTag() {
+ return this.consumerTag;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamCancelOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -45,7 +45,55 @@
public boolean noLocal;
public boolean exclusive;
public boolean nowait;
-
+
+ public void setTicket(int ticket) {
+ this.ticket = ticket;
+ }
+ public int getTicket() {
+ return this.ticket;
+ }
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+ public void setConsumerTag(String consumerTag) {
+ this.consumerTag = consumerTag;
+ }
+ public String getConsumerTag() {
+ return this.consumerTag;
+ }
+
+ public void setNoLocal(boolean noLocal) {
+ this.noLocal = noLocal;
+ }
+ public boolean getNoLocal() {
+ return this.noLocal;
+ }
+
+ public void setExclusive(boolean exclusive) {
+ this.exclusive = exclusive;
+ }
+ public boolean getExclusive() {
+ return this.exclusive;
+ }
+
+ public void setNowait(boolean nowait) {
+ this.nowait = nowait;
+ }
+ public boolean getNowait() {
+ return this.nowait;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamConsumeBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public String consumerTag;
-
+
+ public void setConsumerTag(String consumerTag) {
+ this.consumerTag = consumerTag;
+ }
+ public String getConsumerTag() {
+ return this.consumerTag;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamConsumeOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -43,7 +43,41 @@
public long deliveryTag;
public String exchange;
public String queue;
-
+
+ public void setConsumerTag(String consumerTag) {
+ this.consumerTag = consumerTag;
+ }
+ public String getConsumerTag() {
+ return this.consumerTag;
+ }
+
+ public void setDeliveryTag(long deliveryTag) {
+ this.deliveryTag = deliveryTag;
+ }
+ public long getDeliveryTag() {
+ return this.deliveryTag;
+ }
+
+ public void setExchange(String exchange) {
+ this.exchange = exchange;
+ }
+ public String getExchange() {
+ return this.exchange;
+ }
+
+ public void setQueue(String queue) {
+ this.queue = queue;
+ }
+ public String getQueue() {
+ return this.queue;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamDeliverBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -44,7 +44,48 @@
public String routingKey;
public boolean mandatory;
public boolean immediate;
-
+
+ public void setTicket(int ticket) {
+ this.ticket = ticket;
+ }
+ public int getTicket() {
+ return this.ticket;
+ }
+
+ public void setExchange(String exchange) {
+ this.exchange = exchange;
+ }
+ public String getExchange() {
+ return this.exchange;
+ }
+
+ public void setRoutingKey(String routingKey) {
+ this.routingKey = routingKey;
+ }
+ public String getRoutingKey() {
+ return this.routingKey;
+ }
+
+ public void setMandatory(boolean mandatory) {
+ this.mandatory = mandatory;
+ }
+ public boolean getMandatory() {
+ return this.mandatory;
+ }
+
+ public void setImmediate(boolean immediate) {
+ this.immediate = immediate;
+ }
+ public boolean getImmediate() {
+ return this.immediate;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamPublishBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -43,7 +43,41 @@
public int prefetchCount;
public long consumeRate;
public boolean global;
-
+
+ public void setPrefetchSize(long prefetchSize) {
+ this.prefetchSize = prefetchSize;
+ }
+ public long getPrefetchSize() {
+ return this.prefetchSize;
+ }
+
+ public void setPrefetchCount(int prefetchCount) {
+ this.prefetchCount = prefetchCount;
+ }
+ public int getPrefetchCount() {
+ return this.prefetchCount;
+ }
+
+ public void setConsumeRate(long consumeRate) {
+ this.consumeRate = consumeRate;
+ }
+ public long getConsumeRate() {
+ return this.consumeRate;
+ }
+
+ public void setGlobal(boolean global) {
+ this.global = global;
+ }
+ public boolean getGlobal() {
+ return this.global;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamQosBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamQosOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -43,7 +43,41 @@
public String replyText;
public String exchange;
public String routingKey;
-
+
+ public void setReplyCode(int replyCode) {
+ this.replyCode = replyCode;
+ }
+ public int getReplyCode() {
+ return this.replyCode;
+ }
+
+ public void setReplyText(String replyText) {
+ this.replyText = replyText;
+ }
+ public String getReplyText() {
+ return this.replyText;
+ }
+
+ public void setExchange(String exchange) {
+ this.exchange = exchange;
+ }
+ public String getExchange() {
+ return this.exchange;
+ }
+
+ public void setRoutingKey(String routingKey) {
+ this.routingKey = routingKey;
+ }
+ public String getRoutingKey() {
+ return this.routingKey;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processStreamReturnBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestContentBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public long contentChecksum;
-
+
+ public void setContentChecksum(long contentChecksum) {
+ this.contentChecksum = contentChecksum;
+ }
+ public long getContentChecksum() {
+ return this.contentChecksum;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestContentOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -44,7 +44,48 @@
public long integer3;
public long integer4;
public short operation;
-
+
+ public void setInteger1(short integer1) {
+ this.integer1 = integer1;
+ }
+ public short getInteger1() {
+ return this.integer1;
+ }
+
+ public void setInteger2(int integer2) {
+ this.integer2 = integer2;
+ }
+ public int getInteger2() {
+ return this.integer2;
+ }
+
+ public void setInteger3(long integer3) {
+ this.integer3 = integer3;
+ }
+ public long getInteger3() {
+ return this.integer3;
+ }
+
+ public void setInteger4(long integer4) {
+ this.integer4 = integer4;
+ }
+ public long getInteger4() {
+ return this.integer4;
+ }
+
+ public void setOperation(short operation) {
+ this.operation = operation;
+ }
+ public short getOperation() {
+ return this.operation;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestIntegerBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public long result;
-
+
+ public void setResult(long result) {
+ this.result = result;
+ }
+ public long getResult() {
+ return this.result;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestIntegerOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -42,7 +42,34 @@
public String string1;
public byte[] string2;
public short operation;
-
+
+ public void setString1(String string1) {
+ this.string1 = string1;
+ }
+ public String getString1() {
+ return this.string1;
+ }
+
+ public void setString2(byte[] string2) {
+ this.string2 = string2;
+ }
+ public byte[] getString2() {
+ return this.string2;
+ }
+
+ public void setOperation(short operation) {
+ this.operation = operation;
+ }
+ public short getOperation() {
+ return this.operation;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestStringBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public byte[] result;
-
+
+ public void setResult(byte[] result) {
+ this.result = result;
+ }
+ public byte[] getResult() {
+ return this.result;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestStringOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -42,7 +42,34 @@
public FieldTable table;
public short integerOp;
public short stringOp;
-
+
+ public void setTable(FieldTable table) {
+ this.table = table;
+ }
+ public FieldTable getTable() {
+ return this.table;
+ }
+
+ public void setIntegerOp(short integerOp) {
+ this.integerOp = integerOp;
+ }
+ public short getIntegerOp() {
+ return this.integerOp;
+ }
+
+ public void setStringOp(short stringOp) {
+ this.stringOp = stringOp;
+ }
+ public short getStringOp() {
+ return this.stringOp;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestTableBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -41,7 +41,27 @@
public long integerResult;
public byte[] stringResult;
-
+
+ public void setIntegerResult(long integerResult) {
+ this.integerResult = integerResult;
+ }
+ public long getIntegerResult() {
+ return this.integerResult;
+ }
+
+ public void setStringResult(byte[] stringResult) {
+ this.stringResult = stringResult;
+ }
+ public byte[] getStringResult() {
+ return this.stringResult;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTestTableOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,7 +40,20 @@
}
public FieldTable metaData;
-
+
+ public void setMetaData(FieldTable metaData) {
+ this.metaData = metaData;
+ }
+ public FieldTable getMetaData() {
+ return this.metaData;
+ }
+
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTunnelRequestBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTxCommitBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTxCommitOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTxRollbackBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTxRollbackOkBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTxSelectBody(this);
+ }
public String toString()
{
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java?view=diff&rev=464620&r1=464619&r2=464620
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java Mon Oct 16 11:47:51 2006
@@ -1,20 +1,20 @@
/**
-*
-* Copyright (c) 2006 The Apache Software Foundation
-*
-* Licensed 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.
-*
-*/
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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.activemq.qpid.command;
@@ -40,6 +40,12 @@
}
+
+
+ public Object process(Visitor visitor) throws Exception
+ {
+ return visitor.processTxSelectOkBody(this);
+ }
public String toString()
{