ch.algotrader.broker

Class SimpleTopicRouter<T>

java.lang.Object

ch.algotrader.broker.SimpleTopicRouter<T>

All Implemented Interfaces:

TopicRouter<T>

public class SimpleTopicRouter<T>
extends java.lang.Object
implements TopicRouter<T>

Field Summary

Fields inherited from interface ch.algotrader.broker.TopicRouter

SEPARATOR

Constructor Summary

Constructors

Constructor and Description
SimpleTopicRouter(java.lang.String baseTopic, java.util.function.Function<T,java.lang.String> idExtractor)

Method Summary

Modifier and Type	Method and Description
static java.lang.String	create(java.lang.String baseTopic, java.lang.String id)
Destination	create(T vo, java.util.Optional<java.lang.String> strategyName)
void	postProcess(T event, Message message)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleTopicRouter

public SimpleTopicRouter(java.lang.String baseTopic,
                         java.util.function.Function<T,java.lang.String> idExtractor)

Method Detail

create

public Destination create(T vo,
                          java.util.Optional<java.lang.String> strategyName)

Specified by:

create in interface TopicRouter<T>

postProcess

public void postProcess(T event,
                        Message message)
                 throws JMSException

Specified by:

postProcess in interface TopicRouter<T>

Throws:

JMSException

create

public static java.lang.String create(java.lang.String baseTopic,
                                      java.lang.String id)