akka.zeromq
Class ZMQMessage

java.lang.Object
  akka.zeromq.ZMQMessage

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public class ZMQMessage
extends java.lang.Object
implements scala.Product, scala.Serializable

A message received over the zeromq socket

See Also:

Serialized Form

Constructor Summary

ZMQMessage(Frame frame)

ZMQMessage(Frame[] frameArray)

ZMQMessage(Frame frame1, Frame frame2)

ZMQMessage(scala.collection.Seq<Frame> frames)

Method Summary

static ZMQMessage	apply(byte[] bytes)
static ZMQMessage	apply(com.google.protobuf.Message message)
java.lang.String	firstFrameAsString() Convert the bytes in the first frame to a String, using "UTF-8" charset.
java.lang.String	firstFrameAsString(java.lang.String charsetName) Convert the bytes in the first frame to a String, using specified charset.
scala.collection.Seq<Frame>	frames()
byte[]	payload(int frameIndex)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

ZMQMessage

public ZMQMessage(scala.collection.Seq<Frame> frames)

ZMQMessage

public ZMQMessage(Frame frame)

ZMQMessage

public ZMQMessage(Frame frame1,
                  Frame frame2)

ZMQMessage

public ZMQMessage(Frame[] frameArray)

Method Detail

apply

public static ZMQMessage apply(byte[] bytes)

apply

public static ZMQMessage apply(com.google.protobuf.Message message)

frames

public scala.collection.Seq<Frame> frames()

firstFrameAsString

public java.lang.String firstFrameAsString(java.lang.String charsetName)

Convert the bytes in the first frame to a String, using specified charset.

firstFrameAsString

public java.lang.String firstFrameAsString()

Convert the bytes in the first frame to a String, using "UTF-8" charset.

payload

public byte[] payload(int frameIndex)