Package org.zeromq

Class ZActor.Double

java.lang.Object

org.zeromq.ZActor.Double

All Implemented Interfaces:

ZPoller.EventsHandler, ZStar.Star

Enclosing class:

ZActor

private static final class ZActor.Double
extends java.lang.Object
implements ZPoller.EventsHandler, ZStar.Star

Field Summary

Fields

Modifier and Type	Field	Description
private ZActor.Actor	actor
private ZContext	context
private ZMQ.Socket	pipe
private ZPoller	poller
private java.util.List<ZMQ.Socket>	sockets

Constructor Summary

Constructors

Constructor	Description
Double(ZContext ctx, ZMQ.Socket pipe, ZActor.Actor actor, java.lang.Object... args)

Method Summary

Modifier and Type	Method	Description
boolean	act(int events)	Where acting takes place ... Hint: Can be used to process the events or input acquired from the previous step, or ... Key point: in the middle of a loop. Decision: to act on the next loop or not
int	breathe()	Called when the star in on stage, just before acting. Hint: Can be used to poll events or get input/events from other sources, or ... Key point: a loop just started.
boolean	entract()	Called as an interval between each act. Hint: Can be used to perform decisions to continue next loop or not, or to send computed data to outputs, or ... Key point: at the end of a loop. Decision: to act on the next loop or not
boolean	events(java.nio.channels.SelectableChannel channel, int events)	Called when the poller intercepts events.
boolean	events(ZMQ.Socket socket, int events)	Called when the poller intercepts events.
void	prepare()	Called when the star is in the wings. Hint: Can be used to initialize the service, or ... Key point: no loop has started already.
boolean	renews()	Does the star want to renew for a new performance ? Hint: Can be used to perform decisions to continue looping or not, or to send computed data to outputs, or ... Key point: the inner looping mechanism just ended Decision: to exit or not

Methods inherited from class java.lang.Object

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

Field Detail

poller

private final ZPoller poller

pipe

private final ZMQ.Socket pipe

sockets

private final java.util.List<ZMQ.Socket> sockets

actor

private final ZActor.Actor actor

context

private final ZContext context

Constructor Detail

Double

public Double(ZContext ctx,
              ZMQ.Socket pipe,
              ZActor.Actor actor,
              java.lang.Object... args)

Method Detail

prepare

public void prepare()

Description copied from interface: ZStar.Star

Called when the star is in the wings.
Hint: Can be used to initialize the service, or ...
Key point: no loop has started already.

Specified by:

prepare in interface ZStar.Star

breathe

public int breathe()

Description copied from interface: ZStar.Star

Called when the star in on stage, just before acting.
Hint: Can be used to poll events or get input/events from other sources, or ...
Key point: a loop just started.

Specified by:

breathe in interface ZStar.Star

Returns:

the number of events to process

act

public boolean act(int events)

Description copied from interface: ZStar.Star

Where acting takes place ...
Hint: Can be used to process the events or input acquired from the previous step, or ...
Key point: in the middle of a loop.
Decision: to act on the next loop or not

Specified by:

act in interface ZStar.Star

Parameters:

events - the number of events to process

Returns:

true to continue till the end of the act, false to stop loopS here.

entract

public boolean entract()

Description copied from interface: ZStar.Star

Called as an interval between each act.
Hint: Can be used to perform decisions to continue next loop or not, or to send computed data to outputs, or ...
Key point: at the end of a loop.
Decision: to act on the next loop or not

Specified by:

entract in interface ZStar.Star

Returns:

true to continue acting, false to stop loopS here.

renews

public boolean renews()

Description copied from interface: ZStar.Star

Does the star want to renew for a new performance ? Hint: Can be used to perform decisions to continue looping or not, or to send computed data to outputs, or ...
Key point: the inner looping mechanism just ended
Decision: to exit or not

Specified by:

renews in interface ZStar.Star

Returns:

true to restart acting, false to leave here

events

public boolean events(java.nio.channels.SelectableChannel channel,
                      int events)

Description copied from interface: ZPoller.EventsHandler

Called when the poller intercepts events.

Specified by:

events in interface ZPoller.EventsHandler

Parameters:

channel - the channel with events

events - the interesting events as an ORed combination of IN, OUT, ERR

Returns:

true to continue the polling, false to stop it

events

public boolean events(ZMQ.Socket socket,
                      int events)

Description copied from interface: ZPoller.EventsHandler

Called when the poller intercepts events.

Specified by:

events in interface ZPoller.EventsHandler

Parameters:

socket - the socket with events

events - the interesting events as an ORed combination of IN, OUT, ERR

Returns:

true to continue the polling, false to stop it