Class KafkaSender
java.lang.Object
org.frankframework.extensions.kafka.AbstractKafkaFacade
org.frankframework.extensions.kafka.KafkaSender
- All Implemented Interfaces:
FrankElement
,HasApplicationContext
,HasName
,HasPhysicalDestination
,IConfigurable
,IScopeProvider
,ISender
,NameAware
,org.springframework.beans.factory.Aware
,org.springframework.context.ApplicationContextAware
@Deprecated(forRemoval=false)
@ConfigurationWarning("Experimental and under development. Do not use unless you wish to participate in this development.")
public class KafkaSender
extends AbstractKafkaFacade
implements ISender
Deprecated.
Experimental
ISender
for sending messages to a Kafka instance.
The Kafka integration is still under development so do not
currently use unless you wish to participate in this development.-
Field Summary
Fields inherited from class org.frankframework.extensions.kafka.AbstractKafkaFacade
properties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Deprecated.Configure this component.Deprecated.sendMessage
(Message message, PipeLineSession session) Deprecated.Send a message to some destination (as configured in the Sender object).void
start()
Deprecated.This method will be called to start the sender.void
stop()
Deprecated.Stop/close the sender and deallocate resources.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.context.ApplicationContextAware
setApplicationContext
Methods inherited from interface org.frankframework.core.HasApplicationContext
getApplicationContext, getConfigurationClassLoader
Methods inherited from interface org.frankframework.core.HasPhysicalDestination
getDomain
Methods inherited from interface org.frankframework.core.ISender
consumesSessionVariable, isSynchronous, sendMessageOrThrow
-
Constructor Details
-
KafkaSender
public KafkaSender()Deprecated.
-
-
Method Details
-
configure
Deprecated.Description copied from interface:IConfigurable
Configure this component.configure()
is called once at startup of the framework in the configure method of the owner of thisIConfigurable
. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in theconfigure()
, to improve performance.In the case of a container, this will propagate the configure signal to all components that apply.
- Specified by:
configure
in interfaceIConfigurable
- Overrides:
configure
in classAbstractKafkaFacade
- Throws:
ConfigurationException
- in case it was not able to configure the component.
-
start
public void start()Deprecated.Description copied from interface:ISender
This method will be called to start the sender. After this method is called the sendMessage method may be called. Purpose of this method is to reduce creating connections to databases etc. in thesendMessage()
method. -
stop
public void stop()Deprecated.Description copied from interface:ISender
Stop/close the sender and deallocate resources. -
sendMessage
@Nonnull public SenderResult sendMessage(@Nonnull Message message, @Nonnull PipeLineSession session) throws SenderException Deprecated.Description copied from interface:ISender
Send a message to some destination (as configured in the Sender object). This method may only be called after theconfigure()
method is called.The following table shows the difference between synchronous and a-synchronous senders:
synchronous a-synchronous ISender.isSynchronous()
returnstrue
false
return value of sendMessage()
isthe reply-message the messageId of the message sent the correlationID specified with sendMessage()
may be ignored is sent with the message a {link TimeOutException} may be thrown if a timeout occurs waiting for a reply should not be expected Multiple objects may try to call this method at the same time, from different threads. Implementations of this method should therefore be thread-safe, or
synchronized
.- Specified by:
sendMessage
in interfaceISender
- Throws:
SenderException
-
getPhysicalDestinationName
Deprecated.- Specified by:
getPhysicalDestinationName
in interfaceHasPhysicalDestination
-