public abstract class AggregatingMessageProducer<S,T> extends Object implements MessageDispatcher<S>
Constructor and Description |
---|
AggregatingMessageProducer(String id,
AggregationPolicy<S,T,?> policy) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
abstract void |
dispatch(T message) |
void |
send(S message) |
public AggregatingMessageProducer(String id, AggregationPolicy<S,T,?> policy)
public void send(S message)
send
in interface MessageDispatcher<S>
public abstract void dispatch(T message)
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2018. All rights reserved.