diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2008-04-21 14:03:35 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2008-04-21 14:03:35 +0000 |
| commit | 9930676624d4c27f866c9d40227fd7c282f4dac2 (patch) | |
| tree | ef3639dcdbd8e93160a8286b7f13fecb4e55abcb /java/plugins | |
| parent | 1d69ea16b30dd67ac32683e6dc512f4c58ef93f1 (diff) | |
| download | qpid-python-9930676624d4c27f866c9d40227fd7c282f4dac2.tar.gz | |
Initial checkpoint of queue refactoring work
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/broker-queue-refactor@650148 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/plugins')
2 files changed, 6 insertions, 4 deletions
diff --git a/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java b/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java index 77cc12df7c..600ae3f7be 100644 --- a/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java +++ b/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java @@ -34,7 +34,8 @@ import org.apache.qpid.framing.FieldTable; import org.apache.qpid.server.exchange.AbstractExchange; import org.apache.qpid.server.management.MBeanConstructor; import org.apache.qpid.server.management.MBeanDescription; -import org.apache.qpid.server.queue.AMQMessage; +import org.apache.qpid.server.queue.AMQQueueImpl; +import org.apache.qpid.server.queue.IncomingMessage; import org.apache.qpid.server.queue.AMQQueue; import org.apache.qpid.junit.extensions.util.SizeOf; @@ -191,7 +192,7 @@ public class DiagnosticExchange extends AbstractExchange return false; } - public void route(AMQMessage payload) throws AMQException + public void route(IncomingMessage payload) throws AMQException { Long value = new Long(SizeOf.getUsedMemory()); diff --git a/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java b/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java index f9904a76b9..7589a7974b 100644 --- a/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java +++ b/java/plugins/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java @@ -7,7 +7,8 @@ import org.apache.qpid.AMQException; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.FieldTable; import org.apache.qpid.server.exchange.Exchange; -import org.apache.qpid.server.queue.AMQMessage; +import org.apache.qpid.server.queue.AMQQueueImpl; +import org.apache.qpid.server.queue.IncomingMessage; import org.apache.qpid.server.queue.AMQQueue; import org.apache.qpid.server.virtualhost.VirtualHost; @@ -81,7 +82,7 @@ public class TestExchange implements Exchange { } - public void route(AMQMessage message) throws AMQException + public void route(IncomingMessage message) throws AMQException { } |