Producer

trait Producer extends ProducerSupport

Mixed in by Actor implementations to produce messages to Camel endpoints.

Self Type: Producer with Actor
Annotations: @deprecated
Deprecated: (Since version 2.5.0) Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
Source: Producer.scala

Linear Supertypes

ProducerSupport, CamelSupport, Actor, AnyRef, Any

Known Subclasses

Oneway

Type Hierarchy

Ordering

Alphabetic
By Inheritance

Inherited

Producer
ProducerSupport
CamelSupport
Actor
AnyRef
Any

Implicitly

by any2stringadd
by StringFormat
by Ensuring
by ArrowAssoc

Hide All
Show All

Visibility

Public
All

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

Abstract Value Members

abstract def endpointUri: String
Returns the Camel endpoint URI to produce messages to.
Returns the Camel endpoint URI to produce messages to.

Definition Classes
ProducerSupport

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
def +(other: String): String

Implicit
This member is added by an implicit conversion from Producer to any2stringadd[Producer] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (Producer, B)

Implicit
This member is added by an implicit conversion from Producer to ArrowAssoc[Producer] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def aroundPostRestart(reason: Throwable): Unit
INTERNAL API.
INTERNAL API.
Can be overridden to intercept calls to postRestart. Calls postRestart by default.

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundPostStop(): Unit
INTERNAL API.
INTERNAL API.
Can be overridden to intercept calls to postStop. Calls postStop by default.

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
INTERNAL API.
INTERNAL API.
Can be overridden to intercept calls to preRestart. Calls preRestart by default.

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundPreStart(): Unit
INTERNAL API.
INTERNAL API.
Can be overridden to intercept calls to preStart. Calls preStart by default.

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundReceive(receive: actor.Actor.Receive, msg: Any): Unit
INTERNAL API.
INTERNAL API.
Can be overridden to intercept calls to this actor's current behavior.
receive
current behavior.
msg
current message.

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
final def asInstanceOf[T0]: T0

Definition Classes
Any
val camel: Camel
INTERNAL API Returns a akka.camel.Camel trait which provides access to the CamelExtension.
INTERNAL API Returns a akka.camel.Camel trait which provides access to the CamelExtension.

Attributes
protected
Definition Classes
CamelSupport
implicit def camelContext: DefaultCamelContext
Returns the CamelContext.
Returns the CamelContext. The camelContext is defined implicit for simplifying the use of CamelMessage from the Scala API.

Attributes
protected
Definition Classes
CamelSupport
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate() @throws( ... )
implicit val context: ActorContext
Scala API: Stores the context for this actor, including self, and sender.
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
akka.actor.ActorContext is the Scala API. getContext returns a akka.actor.AbstractActor.ActorContext, which is the Java API of the actor context.

Definition Classes
Actor
def ensuring(cond: (Producer) ⇒ Boolean, msg: ⇒ Any): Producer

Implicit
This member is added by an implicit conversion from Producer to Ensuring[Producer] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (Producer) ⇒ Boolean): Producer

Implicit
This member is added by an implicit conversion from Producer to Ensuring[Producer] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: ⇒ Any): Producer

Implicit
This member is added by an implicit conversion from Producer to Ensuring[Producer] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): Producer

Implicit
This member is added by an implicit conversion from Producer to Ensuring[Producer] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def formatted(fmtstr: String): String

Implicit
This member is added by an implicit conversion from Producer to StringFormat[Producer] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
def headersToCopy: Set[String]
Returns the names of message headers to copy from a request message to a response message.
Returns the names of message headers to copy from a request message to a response message. By default only the CamelMessage.MessageExchangeId is copied. Applications may override this to define an application-specific set of message headers to copy.

Definition Classes
ProducerSupport
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
def oneway: Boolean
If set to false (default), this producer expects a response message from the Camel endpoint.
If set to false (default), this producer expects a response message from the Camel endpoint. If set to true, this producer initiates an in-only message exchange with the Camel endpoint (fire and forget).

Definition Classes
ProducerSupport
def postRestart(reason: Throwable): Unit
User overridable callback: By default it calls preStart().
User overridable callback: By default it calls preStart().
reason
the Throwable that caused the restart to happen Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.

Definition Classes
Actor
Annotations
@throws( classOf[Exception] )
def postStop(): Unit
User overridable callback.
User overridable callback.
Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Definition Classes
Actor
Annotations
@throws( classOf[Exception] )
def preRestart(reason: Throwable, message: Option[Any]): Unit
Scala API: User overridable callback: By default it disposes of all children and then calls postStop().
Scala API: User overridable callback: By default it disposes of all children and then calls postStop().
reason
the Throwable that caused the restart to happen
message
optionally the current message the actor processed when failing, if applicable Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated.

Definition Classes
Actor
Annotations
@throws( classOf[Exception] )
def preStart(): Unit
User overridable callback.
User overridable callback.
Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

Definition Classes
ProducerSupport → Actor
def produce: (Producer.this)#Receive
Produces msg to the endpoint specified by endpointUri.
Produces msg to the endpoint specified by endpointUri. Before the message is actually sent it is pre-processed by calling transformOutgoingMessage. If oneway is true, an in-only message exchange is initiated, otherwise an in-out message exchange.

Attributes
protected
Definition Classes
ProducerSupport
See also
Producer#produce
final def receive: actor.Actor.Receive
Implementation of Actor.receive.
Implementation of Actor.receive. Any messages received by this actor will be produced to the endpoint specified by endpointUri.

Definition Classes
Producer → Actor
def routeResponse(msg: Any): Unit
Called after a response was received from the endpoint specified by endpointUri.
Called after a response was received from the endpoint specified by endpointUri. The response is passed as argument. By default, this method sends the response back to the original sender if oneway is false. If oneway is true, nothing is done. This method may be overridden by subtraits or subclasses (e.g. to forward responses to another actor).

Attributes
protected
Definition Classes
ProducerSupport
implicit final val self: ActorRef
The 'self' field holds the ActorRef for this actor.
The 'self' field holds the ActorRef for this actor.
Can be used to send messages to itself:
```
self ! message
```
Definition Classes
Actor
final def sender(): ActorRef
The reference sender Actor of the last received message.
The reference sender Actor of the last received message. Is defined if the message was sent from another Actor, else deadLetters in akka.actor.ActorSystem.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

Definition Classes
Actor
def supervisorStrategy: SupervisorStrategy
User overridable definition the strategy to use for supervising child actors.
User overridable definition the strategy to use for supervising child actors.

Definition Classes
Actor
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def transformOutgoingMessage(msg: Any): Any
Called before the message is sent to the endpoint specified by endpointUri.
Called before the message is sent to the endpoint specified by endpointUri. The original message is passed as argument. By default, this method simply returns the argument but may be overridden by subtraits or subclasses.

Attributes
protected
Definition Classes
ProducerSupport
def transformResponse(msg: Any): Any
Called before the response message is sent to the original sender.
Called before the response message is sent to the original sender. The original message is passed as argument. By default, this method simply returns the argument but may be overridden by subtraits or subclasses.

Attributes
protected
Definition Classes
ProducerSupport
def unhandled(message: Any): Unit
User overridable callback.
User overridable callback.
Is called when a message isn't handled by the current behavior of the actor by default it fails with either a akka.actor.DeathPactException (in case of an unhandled akka.actor.Terminated message) or publishes an akka.actor.UnhandledMessage to the actor's system's akka.event.EventStream

Definition Classes
Actor
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@native() @throws( ... )
def →[B](y: B): (Producer, B)

Implicit
This member is added by an implicit conversion from Producer to ArrowAssoc[Producer] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Deprecated Value Members

def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
Deprecated
(Since version ) see corresponding Javadoc for more information.

Packages

Producer

trait Producer extends ProducerSupport

Type Members

Abstract Value Members

Concrete Value Members

Deprecated Value Members

Inherited from ProducerSupport

Inherited from CamelSupport

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from Producer to any2stringadd[Producer]

Inherited by implicit conversion StringFormat from Producer to StringFormat[Producer]

Inherited by implicit conversion Ensuring from Producer to Ensuring[Producer]

Inherited by implicit conversion ArrowAssoc from Producer to ArrowAssoc[Producer]

Ungrouped

Packages

Producer 

trait Producer extends ProducerSupport

Type Members

Abstract Value Members

Concrete Value Members

Deprecated Value Members

Inherited from ProducerSupport

Inherited from CamelSupport

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from Producer to any2stringadd[Producer]

Inherited by implicit conversion StringFormat from Producer to StringFormat[Producer]

Inherited by implicit conversion Ensuring from Producer to Ensuring[Producer]

Inherited by implicit conversion ArrowAssoc from Producer to ArrowAssoc[Producer]

Ungrouped

Producer