diff options
10 files changed, 21 insertions, 21 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageAppendMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageAppendMethodHandler.java index 543ea0c7ad..eb4a036bbf 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageAppendMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageAppendMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageAppendBody; @@ -41,7 +41,7 @@ public class MessageAppendMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageAppendBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageCheckpointMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageCheckpointMethodHandler.java index f809dbc4c1..4c897e33e5 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageCheckpointMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageCheckpointMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageCheckpointBody; @@ -41,7 +41,7 @@ public class MessageCheckpointMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageCheckpointBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageCloseMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageCloseMethodHandler.java index cd04e89f6e..4ca6d63d6e 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageCloseMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageCloseMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageCloseBody; @@ -41,7 +41,7 @@ public class MessageCloseMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageCloseBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageEmptyMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageEmptyMethodHandler.java index 76534b285f..93177cd8ec 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageEmptyMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageEmptyMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageEmptyBody; @@ -41,7 +41,7 @@ public class MessageEmptyMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageEmptyBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageOffsetMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageOffsetMethodHandler.java index 80e5412049..155a6157fa 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageOffsetMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageOffsetMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageOffsetBody; @@ -41,7 +41,7 @@ public class MessageOffsetMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageOffsetBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageOkMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageOkMethodHandler.java index 6d1d94de67..5b392eb599 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageOkMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageOkMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageOkBody; @@ -41,7 +41,7 @@ public class MessageOkMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageOkBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageOpenMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageOpenMethodHandler.java index 1535b16563..13e05da85a 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageOpenMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageOpenMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageOpenBody; @@ -41,7 +41,7 @@ public class MessageOpenMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageOpenBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageRejectMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageRejectMethodHandler.java index bbce2ae1ee..92ad14594c 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageRejectMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageRejectMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageRejectBody; @@ -41,7 +41,7 @@ public class MessageRejectMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageRejectBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageResumeMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageResumeMethodHandler.java index 810ed25029..691dd488ff 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageResumeMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageResumeMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageResumeBody; @@ -41,10 +41,10 @@ public class MessageResumeMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageResumeBody> evt) + AMQMethodEvent evt) throws AMQException { - // TODO + System.out.println(""); } } diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java index 6a21bed7b5..25bb9652ac 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java @@ -18,7 +18,7 @@ * under the License. * */ -package org.apache.qpid.server.handler; +package org.apache.qpid.client.handler; import org.apache.qpid.AMQException; import org.apache.qpid.framing.MessageTransferBody; @@ -41,7 +41,7 @@ public class MessageTransferMethodHandler implements StateAwareMethodListener public void methodReceived (AMQStateManager stateManager, AMQProtocolSession protocolSession, - AMQMethodEvent<MessageTransferBody> evt) + AMQMethodEvent evt) throws AMQException { // TODO |