public interface RouterService
extends org.ow2.petals.clientserverapi.jbi.messaging.RouterService
DeliveryChannel
to their destinations.
Perform an address resolution, finding the endpoint(s) satisfying the destination information, and select the appropriate transporter to convey the messages. Resolutions are based on defined rules.
Routes messages pushed from the Transporter
to the target DeliveryChannel
.
Modifier and Type | Field and Description |
---|---|
static String |
COMPONENT_LOGGER_NAME
Logger name of the router component
|
static String |
FRACTAL_SRV_ITF_NAME
Name of the server interface of the Fractal component
|
static String |
PROPERTY_ROUTER_QOS
Constant used to specify the property name to set the router policy.
|
static String |
PROPERTY_ROUTER_SEND_ATTEMPT
Constant used to specify the property name to set the router send attempt.
|
static String |
PROPERTY_ROUTER_SEND_DELAY
Constant used to specify the property name to set the delay between router send attempts.
|
DEFAULT_PAUSE_TRAFFIC_DELAY, DEFAULT_PLATFORM_STRATEGY, DEFAULT_POLICY, DEFAULT_SEND_ATTEMPTS, DEFAULT_SEND_DELAY, DEFAULT_STOP_TRAFFIC_DELAY, DEFAULT_TRANSPORT_QUEUE_MAX_SIZE, DEFAULT_TRANSPORT_QUEUE_OFFERING_TIMEOUT, FAST_POLICY, RELIABLE_POLICY, SECURE_POLICY
Modifier and Type | Method and Description |
---|---|
void |
addComponent(PetalsComponentContext componentContext)
Inform that a component is installing.
|
void |
removeComponent(PetalsComponentContext componentContext)
Inform that a component is uninstalling.
|
void |
sendInNMR(org.ow2.petals.jbi.messaging.exchange.PetalsMessageExchange exchange)
Send the message into the NMR.
|
void |
stopTraffic()
Prepare the router to be definitely stopped.
|
boolean |
waitEndOfPendingExchange(long waitingTime)
Wait end of pending exchanges.
|
static final String FRACTAL_SRV_ITF_NAME
static final String COMPONENT_LOGGER_NAME
static final String PROPERTY_ROUTER_QOS
static final String PROPERTY_ROUTER_SEND_ATTEMPT
static final String PROPERTY_ROUTER_SEND_DELAY
void sendInNMR(org.ow2.petals.jbi.messaging.exchange.PetalsMessageExchange exchange) throws RoutingException
exchange
- RoutingException
- impossible to send the messagevoid addComponent(PetalsComponentContext componentContext) throws RoutingException
Router
must inform its Transporters
about
the component installation.componentContext
- The component contextRoutingException
- impossible to add the componentvoid removeComponent(PetalsComponentContext componentContext) throws RoutingException
Router
must inform its Transporters
about
the component uninstallation.componentContext
- The component contextRoutingException
- impossible to remove the componentvoid stopTraffic()
Prepare the router to be definitely stopped. It means that:
boolean waitEndOfPendingExchange(long waitingTime)
Wait end of pending exchanges.
waitingTime
- The max time to waittrue
if all pending exchanges have terminated during the given max wait time.
false
when the given max wait time is reached and exchanges are always pending.Copyright © 2005-2016 Linagora. All Rights Reserved.