OVERVIEW |  PACKAGE | CONSTR |  FIELDS |  METHODS FRAMES    NO FRAMES INHERITED

net.liftweb.amqp.StringAMQPSender

class StringAMQPSender

class StringAMQPSender(cf : ConnectionFactory, host : String, port : Int, exchange : String, routingKey : String)

 extends AMQPSender[String]

An example subclass of AMQPSender[T] An example of how to send messages to an AMQP queue/exchange. Notice that this is setup with the same params as StringAQMPExample. After making a new instance of StringAMQPExample, just send ExampleAMQPSender ! "hi" to see the message "hi" appear in the output log. Fun and Easy! If you are planning to send lots of messages to lots of different exchange/queues, consider creating Actor-based Senders, that will help your application to scale.


Source: AMQPSender.scala(65)

 Constructors

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

 Fields

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

 Methods

!.. def !(arg0 : T) Unit SpecializedLiftActor
!!.. def !!(arg0 : Any) Box[Any] LiftActor
!!.. def !!(arg0 : Any, arg1 : Long) Box[Any] LiftActor
!<.. def !<(arg0 : Any) LAFuture[Any] LiftActor
!=.. final def !=(arg0 : Any) Boolean Any
!=.. final def !=(arg0 : Object) Boolean AnyRef
!?.. def !?(arg0 : Long, arg1 : Any) Box[Any] LiftActor
!?.. def !?(arg0 : Any) Any LiftActor
==.. final def ==(arg0 : Object) Boolean AnyRef
==.. final def ==(arg0 : Any) Boolean Any
around.. protected def around[R](arg0 : => R) R SpecializedLiftActor
asInstanceOf.. final def asInstanceOf[T0] T0 Any
clone.. protected def clone Object AnyRef
configure.. override def configure(channel : Channel)
Override this to use your own AMQP queue/exchange with the given channel
Channel
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
send.. def send(msg : T) Unit AMQPSender
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 Unit AnyRef
wait.. final def wait(arg0 : Long) Unit AnyRef
wait.. final def wait(arg0 : Long, arg1 : Int) Unit AnyRef
OVERVIEW |  PACKAGE | CONSTR |  FIELDS |  METHODS FRAMES    NO FRAMES INHERITED
Copyright (c) 2006-2010 WorldWide Conferencing, LLC. All Rights Reserved.