StreamEngine

java.lang.Object
- zmq.StreamEngine

All Implemented Interfaces:: IEngine, IMsgSink, IPollEvents

public class StreamEngine
extends java.lang.Object
implements IEngine, IPollEvents, IMsgSink

Field Summary

Fields
Modifier and Type	Field and Description
`private DecoderBase`	`decoder`
`private EncoderBase`	`encoder`
`private java.lang.String`	`endpoint`
`private java.nio.ByteBuffer`	`greeting`
`private static int`	`GREETING_SIZE`
`private java.nio.ByteBuffer`	`greetingOutputBuffer`
`private java.nio.channels.SocketChannel`	`handle`
`private boolean`	`handshaking`
`private java.nio.ByteBuffer`	`inbuf`
`private int`	`insize`
`private boolean`	`ioEnabled`
`private IOObject`	`ioObject`
`private Options`	`options`
`private Transfer`	`outbuf`
`private int`	`outsize`
`private boolean`	`plugged`
`private SessionBase`	`session`
`private SocketBase`	`socket`

Constructor Summary

Constructors
Constructor and Description

StreamEngine(java.nio.channels.SocketChannel handle, Options options, java.lang.String endpoint)

Constructors
Constructor and Description
`StreamEngine(java.nio.channels.SocketChannel handle, Options options, java.lang.String endpoint)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`acceptEvent()`
`void`	`activateIn()`
`void`	`activateOut()`
`void`	`connectEvent()`
`void`	`destroy()`
`private void`	`error()`
`private boolean`	`handshake()`
`void`	`inEvent()`
`private DecoderBase`	`newDecoder(int size, long max, SessionBase session, int version)`
`private EncoderBase`	`newEncoder(int size, SessionBase session, int version)`
`void`	`outEvent()`
`void`	`plug(IOThread ioThread, SessionBase session)`
`int`	`pushMsg(Msg msg)`
`private int`	`read(java.nio.ByteBuffer buf)`
`void`	`terminate()`
`void`	`timerEvent(int id)`
`private void`	`unplug()`
`private int`	`write(Transfer buf)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

GREETING_SIZE
```
private static final int GREETING_SIZE
```
See Also:

Constant Field Values

ioEnabled
```
private boolean ioEnabled
```

handle

private java.nio.channels.SocketChannel handle

inbuf
```
private java.nio.ByteBuffer inbuf
```

insize
```
private int insize
```

decoder
```
private DecoderBase decoder
```

outbuf
```
private Transfer outbuf
```

outsize
```
private int outsize
```

encoder
```
private EncoderBase encoder
```

handshaking
```
private boolean handshaking
```

greeting

private final java.nio.ByteBuffer greeting

greetingOutputBuffer

private final java.nio.ByteBuffer greetingOutputBuffer

session
```
private SessionBase session
```

options
```
private Options options
```

endpoint
```
private java.lang.String endpoint
```

plugged
```
private boolean plugged
```

socket
```
private SocketBase socket
```

ioObject
```
private IOObject ioObject
```

Constructor Detail

StreamEngine

public StreamEngine(java.nio.channels.SocketChannel handle,
                    Options options,
                    java.lang.String endpoint)

Method Detail

newDecoder

private DecoderBase newDecoder(int size,
                               long max,
                               SessionBase session,
                               int version)

newEncoder

private EncoderBase newEncoder(int size,
                               SessionBase session,
                               int version)

destroy
```
public void destroy()
```

plug

public void plug(IOThread ioThread,
                 SessionBase session)

Specified by:: plug in interface IEngine

unplug
```
private void unplug()
```

terminate
```
public void terminate()
```
Specified by:

terminate in interface IEngine

inEvent
```
public void inEvent()
```
Specified by:

inEvent in interface IPollEvents

outEvent
```
public void outEvent()
```
Specified by:

outEvent in interface IPollEvents

connectEvent
```
public void connectEvent()
```
Specified by:

connectEvent in interface IPollEvents

acceptEvent
```
public void acceptEvent()
```
Specified by:

acceptEvent in interface IPollEvents

timerEvent
```
public void timerEvent(int id)
```
Specified by:

timerEvent in interface IPollEvents

activateOut
```
public void activateOut()
```
Specified by:

activateOut in interface IEngine

activateIn
```
public void activateIn()
```
Specified by:

activateIn in interface IEngine

handshake
```
private boolean handshake()
```

pushMsg
```
public int pushMsg(Msg msg)
```
Specified by:

pushMsg in interface IMsgSink

error
```
private void error()
```

write
```
private int write(Transfer buf)
```

read

private int read(java.nio.ByteBuffer buf)

Class StreamEngine

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

GREETING_SIZE

ioEnabled

handle

inbuf

insize

decoder

outbuf

outsize

encoder

handshaking

greeting

greetingOutputBuffer

session

options

endpoint

plugged

socket

ioObject

Constructor Detail

StreamEngine

Method Detail

newDecoder

newEncoder

destroy

plug

unplug

terminate

inEvent

outEvent

connectEvent

acceptEvent

timerEvent

activateOut

activateIn

handshake

pushMsg

error

write

read