Package org.apache.activemq.artemis.core.server.impl

Class DivertImpl

java.lang.Object

org.apache.activemq.artemis.core.server.impl.DivertImpl

All Implemented Interfaces:

Bindable, Divert

public class DivertImpl
extends Object
implements Divert

A DivertImpl simply diverts a message to a different forwardAddress

Constructor Summary

Constructors

Constructor	Description
DivertImpl(SimpleString uniqueName, SimpleString address, SimpleString forwardAddress, SimpleString routingName, boolean exclusive, Filter filter, Transformer transformer, PostOffice postOffice, StorageManager storageManager, ComponentConfigurationRoutingType routingType)

Method Summary

Modifier and Type	Method	Description
SimpleString	getAddress()
Filter	getFilter()
SimpleString	getForwardAddress()
SimpleString	getRoutingName()
ComponentConfigurationRoutingType	getRoutingType()
Transformer	getTransformer()
SimpleString	getUniqueName()
boolean	isExclusive()
void	route(Message message, RoutingContext context)
void	routeWithAck(Message message, RoutingContext context)
void	setFilter(Filter filter)
void	setForwardAddress(SimpleString forwardAddress)
void	setRoutingType(ComponentConfigurationRoutingType routingType)
void	setTransformer(Transformer transformer)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DivertImpl

public DivertImpl(SimpleString uniqueName,
 SimpleString address,
 SimpleString forwardAddress,
 SimpleString routingName,
 boolean exclusive,
 Filter filter,
 Transformer transformer,
 PostOffice postOffice,
 StorageManager storageManager,
 ComponentConfigurationRoutingType routingType)

Method Details

route

public void route(Message message,
 RoutingContext context)
           throws Exception

Specified by:

route in interface Bindable

Throws:

Exception

routeWithAck

public void routeWithAck(Message message,
 RoutingContext context)
                  throws Exception

Specified by:

routeWithAck in interface Bindable

Throws:

Exception

getRoutingName

public SimpleString getRoutingName()

Specified by:

getRoutingName in interface Divert

getUniqueName

public SimpleString getUniqueName()

Specified by:

getUniqueName in interface Divert

isExclusive

public boolean isExclusive()

Specified by:

isExclusive in interface Divert

getAddress

public SimpleString getAddress()

Specified by:

getAddress in interface Divert

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Divert

getTransformer

public Transformer getTransformer()

Specified by:

getTransformer in interface Divert

getForwardAddress

public SimpleString getForwardAddress()

Specified by:

getForwardAddress in interface Divert

getRoutingType

public ComponentConfigurationRoutingType getRoutingType()

Specified by:

getRoutingType in interface Divert

setFilter

public void setFilter(Filter filter)

Specified by:

setFilter in interface Divert

setTransformer

public void setTransformer(Transformer transformer)

Specified by:

setTransformer in interface Divert

setForwardAddress

public void setForwardAddress(SimpleString forwardAddress)

Specified by:

setForwardAddress in interface Divert

setRoutingType

public void setRoutingType(ComponentConfigurationRoutingType routingType)

Specified by:

setRoutingType in interface Divert

toString

public String toString()

Overrides:

toString in class Object