org.springframework.integration.kafka.support
Class ProducerConfiguration<K,V>

java.lang.Object
  extended by org.springframework.integration.kafka.support.ProducerConfiguration<K,V>

public class ProducerConfiguration<K,V>
extends java.lang.Object

Since:
0.5

Constructor Summary
ProducerConfiguration(ProducerMetadata<K,V> producerMetadata, kafka.javaapi.producer.Producer<K,V> producer)
           
 
Method Summary
 boolean equals(java.lang.Object obj)
           
 kafka.javaapi.producer.Producer<K,V> getProducer()
           
 ProducerMetadata<K,V> getProducerMetadata()
           
 int hashCode()
           
 void send(java.lang.String topic, java.lang.Object messageKey, org.springframework.messaging.Message<?> message)
           
 void stop()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ProducerConfiguration

public ProducerConfiguration(ProducerMetadata<K,V> producerMetadata,
                             kafka.javaapi.producer.Producer<K,V> producer)
Method Detail

getProducerMetadata

public ProducerMetadata<K,V> getProducerMetadata()

getProducer

public kafka.javaapi.producer.Producer<K,V> getProducer()

send

public void send(java.lang.String topic,
                 java.lang.Object messageKey,
                 org.springframework.messaging.Message<?> message)
          throws java.lang.Exception
Throws:
java.lang.Exception

equals

public boolean equals(java.lang.Object obj)
Overrides:
equals in class java.lang.Object

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

stop

public void stop()