Package com.codingchili.core.listener

Class BusRouter

java.lang.Object

com.codingchili.core.listener.BusRouter

All Implemented Interfaces:

CoreDeployment, CoreHandler, Receiver<Request>

Direct Known Subclasses:

BusForwarder

public class BusRouter
extends Object
implements CoreHandler

Simple handler that routes messages to the event bus and passes eventbus errors back to sender.

Constructor Summary

Constructors

Constructor	Description
BusRouter()

Method Summary

Modifier and Type	Method	Description
void	handle(Request request)	Handles an incoming request without exception handling.
void	init(CoreContext core)	Init method that is called with the context that the service was deployed from.
protected void	onNodeNotReachable(Request request)
protected void	onNodeTimeout(Request request)
protected void	onRecipientFailure(Request request)
protected void	send(Request request, String target)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.codingchili.core.listener.CoreDeployment

start, stop

Methods inherited from interface com.codingchili.core.listener.CoreHandler

address

Constructor Details

BusRouter

public BusRouter()

Method Details

init

public void init(CoreContext core)

Description copied from interface: CoreDeployment

Init method that is called with the context that the service was deployed from.

Specified by:

init in interface CoreDeployment

Parameters:

core - the core context to use.

handle

public void handle(Request request)

Description copied from interface: Receiver

Handles an incoming request without exception handling.

Specified by:

handle in interface Receiver<Request>

Parameters:

request - the request to be handled.

send

protected void send(Request request,
 String target)

onRecipientFailure

protected void onRecipientFailure(Request request)

onNodeNotReachable

protected void onNodeNotReachable(Request request)

onNodeTimeout

protected void onNodeTimeout(Request request)