public class ChannelSubscription<T> extends BaseSubscription<T>
Constructor and Description |
---|
ChannelSubscription(DisposingExecutor queue,
Callback<T> receiveMethod) |
ChannelSubscription(DisposingExecutor fiber,
Callback<T> receiveMethod,
Filter<T> filter) |
Modifier and Type | Method and Description |
---|---|
protected void |
onMessageOnProducerThread(T msg)
Receives the event and queues the execution on the target execute.
|
getQueue, onMessage
public ChannelSubscription(DisposingExecutor queue, Callback<T> receiveMethod)
public ChannelSubscription(DisposingExecutor fiber, Callback<T> receiveMethod, Filter<T> filter)
protected void onMessageOnProducerThread(T msg)
onMessageOnProducerThread
in class BaseSubscription<T>
Copyright © 2017. All Rights Reserved.