diff options
Diffstat (limited to 'java/plugins/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java')
| -rw-r--r-- | java/plugins/src/main/java/org/apache/qpid/extras/exchanges/example/TestExchange.java | 5 |
1 files changed, 3 insertions, 2 deletions
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 { } |