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(scala.collection.immutable.Seq<ByteString> frames)

Method Summary

static ZMQMessage	apply(scala.collection.Seq<ByteString> frames) Scala API
static <T> ZMQMessage	apply(scala.collection.Seq<T> frames, scala.Function1<T,ByteString> converter)
static ZMQMessage	empty()
ByteString	frame(int frameIndex)
scala.collection.immutable.Seq<ByteString>	frames()
static ZMQMessage	withFrames(ByteString... frames) Java API: create a message from the given frames
static ZMQMessage	withFrames(scala.collection.Seq<ByteString> frames) Java API: create a message from the given frames

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.immutable.Seq<ByteString> frames)

Method Detail

withFrames

public static ZMQMessage withFrames(ByteString... frames)

Java API: create a message from the given frames

Parameters:

frames - the frames of the returned ZMQMessage

Returns:

a ZMQMessage with the given frames

empty

public static ZMQMessage empty()

apply

public static ZMQMessage apply(scala.collection.Seq<ByteString> frames)

Scala API

Parameters:

frames - the frames of the returned ZMQMessage

Returns:

a ZMQMessage with the given frames

withFrames

public static ZMQMessage withFrames(scala.collection.Seq<ByteString> frames)

Java API: create a message from the given frames

Parameters:

frames - the frames of the returned ZMQMessage

Returns:

a ZMQMessage with the given frames

apply

public static <T> ZMQMessage apply(scala.collection.Seq<T> frames,
                                   scala.Function1<T,ByteString> converter)

frames

public scala.collection.immutable.Seq<ByteString> frames()

frame

public ByteString frame(int frameIndex)