Uses of Class
com.swiftmq.impl.routing.single.connection.RoutingConnection
Package
Description
-
Uses of RoutingConnection in com.swiftmq.impl.routing.single.connection.event
Modifier and TypeMethodDescriptionvoid
ActivationListener.activated
(RoutingConnection routingConnection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.connection.stage
Modifier and TypeMethodDescriptionstatic Stage
StageFactory.createFirstStage
(SwiftletContext ctx, RoutingConnection routingConnection, String protocol) ModifierConstructorDescriptionProtocolSelectStage
(SwiftletContext ctx, RoutingConnection routingConnection, boolean listener) Stage
(SwiftletContext ctx, RoutingConnection routingConnection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.connection.v942
ModifierConstructorDescriptionAuthStage
(SwiftletContext ctx, RoutingConnection routingConnection, ConnectReplyRequest connectReply) ConnectStage
(SwiftletContext ctx, RoutingConnection routingConnection) NonXADeliveryStage
(SwiftletContext ctx, RoutingConnection routingConnection) ThrottleQueue
(SwiftletContext ctx, RoutingConnection connection) XADeliveryStage
(SwiftletContext ctx, RoutingConnection routingConnection) XARecoveryStage
(SwiftletContext ctx, RoutingConnection routingConnection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.manager
Modifier and TypeFieldDescriptionprotected Map<String,
RoutingConnection> ConnectionManager.connections
-
Uses of RoutingConnection in com.swiftmq.impl.routing.single.manager.event
-
Uses of RoutingConnection in com.swiftmq.impl.routing.single.manager.po
ModifierConstructorDescriptionPOAddObject
(POCallback callback, Semaphore semaphore, RoutingConnection connection) PORemoveObject
(POCallback callback, Semaphore semaphore, RoutingConnection connection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.route
Modifier and TypeMethodDescriptionvoid
RouteExchanger.activated
(RoutingConnection routingConnection) RouteTable.getConnectionRoutes
(RoutingConnection routingConnection) void
RouteExchanger.processRoute
(RoutingConnection routingConnection, Route route) RouteTable.removeConnectionRoutes
(RoutingConnection routingConnection) void
Route.setRoutingConnection
(RoutingConnection connection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.route.po
Modifier and TypeMethodDescriptionPOConnectionActivatedObject.getRoutingConnection()
POConnectionRemoveObject.getRoutingConnection()
ModifierConstructorDescriptionPOConnectionActivatedObject
(RoutingConnection routingConnection) POConnectionRemoveObject
(RoutingConnection routingConnection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.route.v400
Modifier and TypeMethodDescriptionvoid
RouteImpl.setRoutingConnection
(RoutingConnection routingConnection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.schedule
Modifier and TypeMethodDescriptionprotected RoutingConnection
DefaultScheduler.getNextConnection()
protected RoutingConnection
RoundRobinScheduler.getNextConnection()
protected abstract RoutingConnection
Scheduler.getNextConnection()
DefaultScheduler.ConnectionEntry.getRoutingConnection()
Modifier and TypeMethodDescriptionprotected void
Scheduler.connectionAdded
(RoutingConnection connection) protected void
Scheduler.connectionRemoved
(RoutingConnection connection) void
DefaultScheduler.removeRoutingConnection
(RoutingConnection routingConnection) abstract void
Scheduler.removeRoutingConnection
(RoutingConnection routingConnection) void
SchedulerRegistry.removeRoutingConnection
(RoutingConnection routingConnection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.schedule.po
Modifier and TypeMethodDescriptionPOConnectionAddedObject.getConnection()
POConnectionRemovedObject.getConnection()
ModifierConstructorDescriptionPOConnectionAddedObject
(RoutingConnection connection) POConnectionRemovedObject
(RoutingConnection connection) -
Uses of RoutingConnection in com.swiftmq.impl.routing.single.smqpr
ModifierConstructorDescriptionSMQRVisitor
(SwiftletContext ctx, RoutingConnection routingConnection)