Lift AMQP 2.0 API : net.liftweb.amqp.AMQPDispatcher

net.liftweb.amqp.AMQPDispatcher

class AMQPDispatcher

abstract class AMQPDispatcher[T](cf : ConnectionFactory, host : String, port : Int)


        

 extends
        LiftActor

An actor that serves as an endpoint for AMQP messages of serialized type T coming into a specific queue/exchange. To listen for messages coming into that queue/exchange, send this actor an AMQPAddListener message. For each message containing a value of type T, all listeners will be send an AMQPMessage contaning that value. See also Enterprise Integration Patterns pp. 508-514

author: - Steve Jenson (stevej@pobox.com)

Source: AMQPDispatcher.scala(60)

Direct Known Subclasses

ExampleSerializedAMQPDispatcher,

Constructors

def this(cf : ConnectionFactory, host : String, port : Int)

Fields

aroundLoans..	`protected def aroundLoans`	List[CommonLoanWrapper]	SpecializedLiftActor
channel..	`var channel`	Channel
conn..	`var conn`	Connection
exceptionHandler..	`protected def exceptionHandler`	PartialFunction[Throwable, Unit]	SpecializedLiftActor
highPriorityReceive..	`protected def highPriorityReceive`	Box[PartialFunction[T, Unit]]	SpecializedLiftActor
messageHandler..	`protected def messageHandler`	PartialFunction[Any, Unit]

Methods

!..	`def !(arg0 : T)`	Unit	SpecializedLiftActor
!!..	`def !!(arg0 : Any, arg1 : Long)`	Box[Any]	LiftActor
!!..	`def !!(arg0 : Any)`	Box[Any]	LiftActor
!<..	`def !<(arg0 : Any)`	LAFuture[Any]	LiftActor
!=..	`final def !=(arg0 : Object)`	Boolean	AnyRef
!=..	`final def !=(arg0 : Any)`	Boolean	Any
!?..	`def !?(arg0 : Any)`	Any	LiftActor
!?..	`def !?(arg0 : Long, arg1 : Any)`	Box[Any]	LiftActor
==..	`final def ==(arg0 : Any)`	Boolean	Any
==..	`final def ==(arg0 : Object)`	Boolean	AnyRef
around..	`protected def around[R](arg0 : => R)`	R	SpecializedLiftActor
asInstanceOf..	`final def asInstanceOf[T0]`	T0	Any
clone..	`protected def clone`	Object	AnyRef
configure..	`abstract def configure(channel : Channel)` Override this to configure the Channel and Consumer	Unit
eq..	`final def eq(arg0 : Object)`	Boolean	AnyRef
equals..	`def equals(arg0 : Any)`	Boolean	AnyRef
execTranslate..	`protected override def execTranslate(arg0 : (Any) => Unit)`	Unit	LiftActor
finalize..	`protected def finalize`	Unit	AnyRef
forwardMessageTo..	`protected final def forwardMessageTo(arg0 : Any, arg1 : TypedActor[Any, Any])`	Unit	LiftActor
getClass..	`final def getClass`	Class[Any]	AnyRef
hashCode..	`def hashCode`	Int	AnyRef
insertMsgAtHeadOfQueue_!..	`protected def insertMsgAtHeadOfQueue_!(arg0 : T)`	Unit	SpecializedLiftActor
isInstanceOf..	`final def isInstanceOf[T0]`	Boolean	Any
ne..	`final def ne(arg0 : Object)`	Boolean	AnyRef
notify..	`final def notify`	Unit	AnyRef
notifyAll..	`final def notifyAll`	Unit	AnyRef
reply..	`protected def reply(arg0 : Any)`	Unit	LiftActor
synchronized..	`final def synchronized[T0](arg0 : T0)`	T0	AnyRef
testTranslate..	`protected override def testTranslate(arg0 : (Any) => Boolean)`	Boolean	LiftActor
toString..	`def toString`	String	AnyRef
wait..	`final def wait(arg0 : Long, arg1 : Int)`	Unit	AnyRef
wait..	`final def wait`	Unit	AnyRef
wait..	`final def wait(arg0 : Long)`	Unit	AnyRef

Copyright (c) 2006-2010 WorldWide Conferencing, LLC. All Rights Reserved.