Author: kpvdr
Date: Tue Jan 9 11:47:02 2007
New Revision: 494541
URL: http://svn.apache.org/viewvc?view=rev&rev=494541
Log:
New broker Messafe class handelrs added, removed old Basic* handlers; New
framing Request and Response classes added
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageAppendHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCancelHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCheckpointHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCloseHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageConsumeHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageEmptyHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageGetHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOffsetHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOkHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOpenHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRecoverHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRejectHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageResumeHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageTransferHandler.java
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
- copied, changed from r494058,
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
- copied, changed from r494058,
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java
Removed:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/BasicAckMethodHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/BasicCancelMethodHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/BasicQosHandler.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java
incubator/qpid/branches/qpid.0-9/java/common/protocol-version.xml
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageAppendHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageAppendHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageAppendHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageAppendHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageAppendBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageAppendHandler implements
StateAwareMethodListener<MessageAppendBody>
+{
+ private static MessageAppendHandler _instance = new MessageAppendHandler();
+
+ public static MessageAppendHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageAppendHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageAppendBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCancelHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCancelHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCancelHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCancelHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageCancelBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageCancelHandler implements
StateAwareMethodListener<MessageCancelBody>
+{
+ private static MessageCancelHandler _instance = new MessageCancelHandler();
+
+ public static MessageCancelHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageCancelHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageCancelBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCheckpointHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCheckpointHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCheckpointHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCheckpointHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageCheckpointBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageCheckpointHandler implements
StateAwareMethodListener<MessageCheckpointBody>
+{
+ private static MessageCheckpointHandler _instance = new
MessageCheckpointHandler();
+
+ public static MessageCheckpointHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageCheckpointHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageCheckpointBody>
evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCloseHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCloseHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCloseHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageCloseHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageCloseBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageCloseHandler implements
StateAwareMethodListener<MessageCloseBody>
+{
+ private static MessageCloseHandler _instance = new MessageCloseHandler();
+
+ public static MessageCloseHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageCloseHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageCloseBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageConsumeHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageConsumeHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageConsumeHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageConsumeHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageConsumeBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageConsumeHandler implements
StateAwareMethodListener<MessageConsumeBody>
+{
+ private static MessageConsumeHandler _instance = new
MessageConsumeHandler();
+
+ public static MessageConsumeHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageConsumeHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageConsumeBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageEmptyHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageEmptyHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageEmptyHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageEmptyHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageEmptyBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageEmptyHandler implements
StateAwareMethodListener<MessageEmptyBody>
+{
+ private static MessageEmptyHandler _instance = new MessageEmptyHandler();
+
+ public static MessageEmptyHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageEmptyHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageEmptyBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageGetHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageGetHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageGetHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageGetHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,47 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageGetBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageGetHandler implements
StateAwareMethodListener<MessageGetBody>
+{
+ private static MessageGetHandler _instance = new MessageGetHandler();
+
+ public static MessageGetHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageGetHandler() {}
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageGetBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOffsetHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOffsetHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOffsetHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOffsetHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageOffsetBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageOffsetHandler implements
StateAwareMethodListener<MessageOffsetBody>
+{
+ private static MessageOffsetHandler _instance = new MessageOffsetHandler();
+
+ public static MessageOffsetHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageOffsetHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageOffsetBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOkHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOkHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOkHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOkHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageOkBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageOkHandler implements
StateAwareMethodListener<MessageOkBody>
+{
+ private static MessageOkHandler _instance = new MessageOkHandler();
+
+ public static MessageOkHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageOkHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageOkBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOpenHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOpenHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOpenHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageOpenHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageOpenBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageOpenHandler implements
StateAwareMethodListener<MessageOpenBody>
+{
+ private static MessageOpenHandler _instance = new MessageOpenHandler();
+
+ public static MessageOpenHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageOpenHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageOpenBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageQosHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageQosBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageQosHandler implements
StateAwareMethodListener<MessageQosBody>
+{
+ private static MessageQosHandler _instance = new MessageQosHandler();
+
+ public static MessageQosHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageQosHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageQosBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRecoverHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRecoverHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRecoverHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRecoverHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageRecoverBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageRecoverHandler implements
StateAwareMethodListener<MessageRecoverBody>
+{
+ private static MessageRecoverHandler _instance = new
MessageRecoverHandler();
+
+ public static MessageRecoverHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageRecoverHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageRecoverBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRejectHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRejectHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRejectHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageRejectHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageRejectBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageRejectHandler implements
StateAwareMethodListener<MessageRejectBody>
+{
+ private static MessageRejectHandler _instance = new MessageRejectHandler();
+
+ public static MessageRejectHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageRejectHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageRejectBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageResumeHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageResumeHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageResumeHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageResumeHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageResumeBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageResumeHandler implements
StateAwareMethodListener<MessageResumeBody>
+{
+ private static MessageResumeHandler _instance = new MessageResumeHandler();
+
+ public static MessageResumeHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageResumeHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageResumeBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Added:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageTransferHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageTransferHandler.java?view=auto&rev=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageTransferHandler.java
(added)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/handler/MessageTransferHandler.java
Tue Jan 9 11:47:02 2007
@@ -0,0 +1,48 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.server.handler;
+
+import org.apache.qpid.framing.MessageTransferBody;
+import org.apache.qpid.server.state.StateAwareMethodListener;
+
+public class MessageTransferHandler implements
StateAwareMethodListener<MessageTransferBody>
+{
+ private static MessageTransferHandler _instance = new
MessageTransferHandler();
+
+ public static MessageTransferHandler getInstance()
+ {
+ return _instance;
+ }
+
+ private MessageTransferHandler() {}
+
+
+ public void methodReceived (AMQStateManager stateManager,
+ QueueRegistry
queueRegistry,
+ ExchangeRegistry exchangeRegistry,
+ AMQProtocolSession protocolSession,
+ AMQMethodEvent<MessageTransferBody> evt)
+ throws AMQException
+ {
+ // TODO
+ }
+}
+
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java?view=diff&rev=494541&r1=494540&r2=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
Tue Jan 9 11:47:02 2007
@@ -195,7 +195,15 @@
{
AMQFrame frame = (AMQFrame) message;
- if (frame.bodyFrame instanceof AMQMethodBody)
+ if (frame.bodyFrame instanceof AMQRequest)
+ {
+ requestFrameReceived(frame);
+ }
+ else if (frame.bodyFrame instanceof AMQResponse)
+ {
+ responseFrameReceived(frame);
+ }
+ else if (frame.bodyFrame instanceof AMQMethodBody)
{
methodFrameReceived(frame);
}
@@ -213,6 +221,22 @@
writeFrame(e.getReturnMessage(frame.channel));
}
}
+ }
+ }
+
+ private void requestFrameReceived(AMQFrame frame)
+ {
+ if (_logger.isDebugEnabled())
+ {
+ _logger.debug("Request frame received: " + frame);
+ }
+ }
+
+ private void responseFrameReceived(AMQFrame frame)
+ {
+ if (_logger.isDebugEnabled())
+ {
+ _logger.debug("Response frame received: " + frame);
}
}
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java?view=diff&rev=494541&r1=494540&r2=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java
Tue Jan 9 11:47:02 2007
@@ -110,12 +110,21 @@
frame2handlerMap.put(ExchangeDeclareBody.class,
ExchangeDeclareHandler.getInstance());
frame2handlerMap.put(ExchangeDeleteBody.class,
ExchangeDeleteHandler.getInstance());
frame2handlerMap.put(ExchangeBoundBody.class,
ExchangeBoundHandler.getInstance());
- frame2handlerMap.put(BasicAckBody.class,
BasicAckMethodHandler.getInstance());
- frame2handlerMap.put(BasicRecoverBody.class,
BasicRecoverMethodHandler.getInstance());
- frame2handlerMap.put(BasicConsumeBody.class,
BasicConsumeMethodHandler.getInstance());
- frame2handlerMap.put(BasicCancelBody.class,
BasicCancelMethodHandler.getInstance());
- frame2handlerMap.put(BasicPublishBody.class,
BasicPublishMethodHandler.getInstance());
- frame2handlerMap.put(BasicQosBody.class,
BasicQosHandler.getInstance());
+ frame2handlerMap.put(MessageAppendBody.class,
MessageAppendHandler.getInstance());
+ frame2handlerMap.put(MessageCancelBody.class,
MessageCancelHandler.getInstance());
+ frame2handlerMap.put(MessageCheckpointBody.class,
MessageCheckpointHandler.getInstance());
+ frame2handlerMap.put(MessageCloseBody.class,
MessageCloseHandler.getInstance());
+ frame2handlerMap.put(MessageConsumeBody.class,
MessageConsumeHandler.getInstance());
+ frame2handlerMap.put(MessageEmptyBody.class,
MessageEmptyHandler.getInstance());
+ frame2handlerMap.put(MessageGetBody.class,
MessageGetHandler.getInstance());
+ frame2handlerMap.put(MessageOffsetBody.class,
MessageOffsetHandler.getInstance());
+ frame2handlerMap.put(MessageOkBody.class,
MessageOkHandler.getInstance());
+ frame2handlerMap.put(MessageOpenBody.class,
MessageOpenHandler.getInstance());
+ frame2handlerMap.put(MessageQosBody.class,
MessageQosHandler.getInstance());
+ frame2handlerMap.put(MessageRecoverBody.class,
MessageRecoverHandler.getInstance());
+ frame2handlerMap.put(MessageRejectBody.class,
MessageRejectHandler.getInstance());
+ frame2handlerMap.put(MessageResumeBody.class,
MessageResumeHandler.getInstance());
+ frame2handlerMap.put(MessageTransferBody.class,
MessageTransferHandler.getInstance());
frame2handlerMap.put(QueueBindBody.class,
QueueBindHandler.getInstance());
frame2handlerMap.put(QueueDeclareBody.class,
QueueDeclareHandler.getInstance());
frame2handlerMap.put(QueueDeleteBody.class,
QueueDeleteHandler.getInstance());
Modified: incubator/qpid/branches/qpid.0-9/java/common/protocol-version.xml
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/common/protocol-version.xml?view=diff&rev=494541&r1=494540&r2=494541
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/common/protocol-version.xml (original)
+++ incubator/qpid/branches/qpid.0-9/java/common/protocol-version.xml Tue Jan
9 11:47:02 2007
@@ -27,8 +27,8 @@
<property name="generated.dir"
location="${generated.path}/${generated.package}" />
<property name="generated.timestamp" location="${generated.dir}/timestamp" />
<property name="xml.spec.dir" location="${topDirectoryLocation}/../specs" />
- <property name="xml.spec.deps" value="amqp.0-9.xml cluster.0-9.xml
amqp-nogen.0-9.xml" />
- <property name="xml.spec.list" value="${xml.spec.dir}/amqp.0-9.xml
${xml.spec.dir}/cluster.0-9.xml ${xml.spec.dir}/amqp-nogen.0-9.xml" />
+ <property name="xml.spec.deps" value="amqp.0-9.xml cluster.0-9.xml
exchange-bound.0-9.xml amqp-nogen.0-9.xml" />
+ <property name="xml.spec.list" value="${xml.spec.dir}/amqp.0-9.xml
${xml.spec.dir}/cluster.0-9.xml ${xml.spec.dir}/exchange-bound.0-9.xml
${xml.spec.dir}/amqp-nogen.0-9.xml" />
<target name="generate" depends="compile_generator,check_generate_deps"
unless="generation.notRequired">
<mkdir dir="${generated.dir}"/>
Copied:
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
(from r494058,
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java)
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java?view=diff&rev=494541&p1=incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java&r1=494058&p2=incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java&r2=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
Tue Jan 9 11:47:02 2007
@@ -22,7 +22,7 @@
import org.apache.mina.common.ByteBuffer;
-public class AMQRequest extends AMQBody
+public class AMQRequestBody extends AMQBody
{
public static final byte TYPE = (byte)AmqpConstants.frameRequestAsInt();
@@ -33,7 +33,7 @@
// Constructor
- public AMQRequest() {}
+ public AMQRequestBody() {}
// Field methods
@@ -72,7 +72,7 @@
public static AMQFrame createAMQFrame(int channelId, long requestId,
long responseMark, AMQMethodBody methodPayload)
{
- AMQResponse responseFrame = new AMQResponse();
+ AMQResponseBody responseFrame = new AMQResponseBody();
responseFrame.requestId = requestId;
responseFrame.responseMark = responseMark;
responseFrame.methodPayload = methodPayload;
Copied:
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
(from r494058,
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java)
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java?view=diff&rev=494541&p1=incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java&r1=494058&p2=incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java&r2=494541
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
Tue Jan 9 11:47:02 2007
@@ -22,36 +22,20 @@
import org.apache.mina.common.ByteBuffer;
-public class AMQResponse extends AMQBody
+public class AMQResponseBody extends AMQRequestBody
{
public static final byte TYPE = (byte)AmqpConstants.frameResponseAsInt();
// Fields declared in specification
- public long requestId;
- public long responseMark;
public int batchOffset;
- public AMQMethodBody methodPayload;
// Constructor
- public AMQResponse() {}
+ public AMQResponseBody() {}
// Field methods
- public long getRequestId() { return requestId; }
- public long getResponseMark() { return responseMark; }
public int getBatchOffset() { return batchOffset; }
- public AMQMethodBody getMethodPayload() { return methodPayload; }
-
- protected byte getFrameType()
- {
- return TYPE;
- }
-
- protected int getSize()
- {
- return 8 + 8 + 4 + methodPayload.getBodySize();
- }
-
+
protected void writePayload(ByteBuffer buffer)
{
EncodingUtils.writeLong(buffer, requestId);
@@ -72,7 +56,7 @@
public static AMQFrame createAMQFrame(int channelId, long requestId,
long responseMark, int batchOffset, AMQMethodBody methodPayload)
{
- AMQResponse responseFrame = new AMQResponse();
+ AMQResponseBody responseFrame = new AMQResponseBody();
responseFrame.requestId = requestId;
responseFrame.responseMark = responseMark;
responseFrame.batchOffset = batchOffset;
