Class AMQPRoutingHandler
java.lang.Object
org.apache.activemq.artemis.core.server.routing.RoutingHandler<AMQPRoutingContext>
org.apache.activemq.artemis.protocol.amqp.proton.AMQPRoutingHandler
public class AMQPRoutingHandler
extends org.apache.activemq.artemis.core.server.routing.RoutingHandler<AMQPRoutingContext>
-
Constructor Summary
ConstructorsConstructorDescriptionAMQPRoutingHandler(org.apache.activemq.artemis.core.server.ActiveMQServer server) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidredirect(AMQPRoutingContext context) protected voidrefuse(AMQPRoutingContext context) booleanroute(AMQPConnectionContext connectionContext, org.apache.qpid.proton.engine.Connection protonConnection) Methods inherited from class org.apache.activemq.artemis.core.server.routing.RoutingHandler
getServer, route
-
Constructor Details
-
AMQPRoutingHandler
public AMQPRoutingHandler(org.apache.activemq.artemis.core.server.ActiveMQServer server)
-
-
Method Details
-
route
public boolean route(AMQPConnectionContext connectionContext, org.apache.qpid.proton.engine.Connection protonConnection) throws Exception - Throws:
Exception
-
refuse
- Specified by:
refusein classorg.apache.activemq.artemis.core.server.routing.RoutingHandler<AMQPRoutingContext>
-
redirect
- Specified by:
redirectin classorg.apache.activemq.artemis.core.server.routing.RoutingHandler<AMQPRoutingContext>
-