com.neeve.sma.impl.loopback
Class LoopbackBus.TestController

java.lang.Object
  com.neeve.sma.impl.loopback.LoopbackBus.TestController

Enclosing class:

LoopbackBus

public final class LoopbackBus.TestController
extends Object

Implements an agent's test controller.

Constructor Summary

LoopbackBus.TestController()

Method Summary

void	forward(LoopbackMessageChannel channel, String topic, Object message, MessageMetadata metadata, long originTs, long preWireTs) Forward a message to agents with matching subscriptions

Methods inherited from class java.lang.Object

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

Constructor Detail

LoopbackBus.TestController

public LoopbackBus.TestController()

Method Detail

forward

public final void forward(LoopbackMessageChannel channel,
                          String topic,
                          Object message,
                          MessageMetadata metadata,
                          long originTs,
                          long preWireTs)
                   throws Exception

Forward a message to agents with matching subscriptions

Throws:

Exception