Functions — github.com/Bluelock/camel-spring-amqp

hub / github.com/Bluelock/camel-spring-amqp / functions

Functions195 in github.com/Bluelock/camel-spring-amqp

⨍ Functions 195◇ Types & classes 33

↓ 31 callersMethodequals

(Object obj)

src/test/java/amqp/spring/converter/StringConverterTest.java:35

↓ 18 callersMethodgetKey

(Message message)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:248

↓ 8 callersMethodgetAmqpTemplate

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:127

↓ 8 callersMethodtoString

()

src/test/java/amqp/spring/converter/StringConverterTest.java:57

↓ 7 callersMethodsetContentType

(String contentType)

src/main/java/amqp/spring/converter/StringConverter.java:28

↓ 6 callersMethodgetValue

()

src/test/java/amqp/spring/converter/StringConverterTest.java:32

↓ 5 callersMethodgetContentType

()

src/main/java/amqp/spring/converter/StringConverter.java:24

↓ 5 callersMethodisUsingDefaultExchange

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:191

↓ 5 callersMethodshutdown

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:155

↓ 4 callersMethodcopyHeaders

(Message msg, Map<String, Object> headers)

src/main/java/amqp/spring/camel/component/SpringAMQPHeader.java:75

↓ 4 callersMethodgetConnectionFactory

()

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:73

↓ 4 callersMethodgetConverters

()

src/main/java/amqp/spring/converter/ContentTypeConverterFactory.java:28

↓ 4 callersMethodstop

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:149

↓ 4 callersMethodtoAMQPMessage

(MessageConverter msgConverter)

src/main/java/amqp/spring/camel/component/SpringAMQPMessage.java:69

↓ 3 callersMethodcreateConsumer

(Processor processor)

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:97

↓ 3 callersMethodfromAMQPMessage

(MessageConverter msgConverter, org.springframework.amqp.core.Message amqpMessage)

src/main/java/amqp/spring/camel/component/SpringAMQPMessage.java:32

↓ 3 callersMethodonClose

(Connection connection)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:100

↓ 3 callersMethodparseKeyValues

(String routingKey)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:80

↓ 3 callersMethodstart

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:143

↓ 2 callersMethodcreateAMQPExchange

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:284

↓ 2 callersMethoddeclareExchange

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:336

↓ 2 callersMethodfindRootCause

(Throwable t)

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:165

↓ 2 callersMethodfromMessage

(Message message)

src/main/java/amqp/spring/converter/StringConverter.java:59

↓ 2 callersMethodfromMessage

(Message message)

src/main/java/amqp/spring/converter/ContentTypeConverterFactory.java:64

↓ 2 callersMethodgetAcknowledgeMode

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:223

↓ 2 callersMethodgetAmqpAdministration

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:119

↓ 2 callersMethodgetExchangeName

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:183

↓ 2 callersMethodgetExchangePattern

(org.springframework.amqp.core.Message amqpMessage)

src/main/java/amqp/spring/camel/component/SpringAMQPMessage.java:59

↓ 2 callersMethodgetQueueName

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:195

↓ 2 callersMethodgetRoutingKey

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:203

↓ 2 callersMethodgetTimeToLive

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:251

↓ 2 callersMethodgetType

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:235

↓ 2 callersMethodidenticalConnectionFactories

(ConnectionFactory cf, ConnectionFactory candidateCF)

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:170

↓ 2 callersMethodpostProcessMessage

(Message msg)

src/main/java/amqp/spring/camel/component/SpringAMQPMessage.java:95

↓ 2 callersMethodsetAmqpTemplate

(AmqpTemplate amqpTemplate)

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:155

↓ 2 callersMethodsetBasicPropertiesFromHeaders

(Message msg, Map<String, Object> headers)

src/main/java/amqp/spring/camel/component/SpringAMQPHeader.java:23

↓ 2 callersMethodsetBasicPropertiesToHeaders

(SpringAMQPMessage msg, Message amqpMessage)

src/main/java/amqp/spring/camel/component/SpringAMQPHeader.java:60

↓ 2 callersMethodsetConcurrentConsumers

(int concurrentConsumers)

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:147

↓ 2 callersMethodsetDefaultContentType

(String defaultContentType)

src/main/java/amqp/spring/converter/ContentTypeConverterFactory.java:40

↓ 2 callersMethodsetFallbackConverter

(MessageConverter fallbackConverter)

src/main/java/amqp/spring/converter/ContentTypeConverterFactory.java:48

↓ 2 callersMethodsetPrefetchCount

(int prefetchCount)

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:139

↓ 2 callersMethodsetValue

(String value)

src/test/java/amqp/spring/converter/ContentTypeConverterFactoryTest.java:65

↓ 1 callersMethodcreateEndpoint

(String uri, String remaining, Map<String, Object> parameters)

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:64

↓ 1 callersMethodcreateProducer

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:83

↓ 1 callersMethoddeclareAMQPEntities

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:330

↓ 1 callersMethoddeclareBinding

(org.springframework.amqp.core.Exchange exchange, Queue queue)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:371

↓ 1 callersMethoddeclareQueue

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:356

↓ 1 callersMethodfromMessage

(Message message)

src/main/java/amqp/spring/converter/XStreamConverter.java:84

↓ 1 callersMethodgetAdviceChain

Do not have Spring AMQP re-try messages upon failure, leave it to Camel @return An advice chain populated with a NeverRetryPolicy

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:178

↓ 1 callersMethodgetAmqpAdministration

()

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:87

↓ 1 callersMethodgetAmqpTemplate

()

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:126

↓ 1 callersMethodgetConcurrentConsumers

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:143

↓ 1 callersMethodgetEncoding

()

src/main/java/amqp/spring/converter/StringConverter.java:32

↓ 1 callersMethodgetEncoding

()

src/main/java/amqp/spring/converter/XStreamConverter.java:48

↓ 1 callersMethodgetErrorHandler

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:160

↓ 1 callersMethodgetPrefetchCount

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:135

↓ 1 callersMethodisAutoReply

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:167

↓ 1 callersMethodisHa

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:159

↓ 1 callersMethodonCreate

(Connection connection)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:95

↓ 1 callersMethodprocess

(Exchange exchange, AsyncCallback callback)

src/main/java/amqp/spring/camel/component/SpringAMQPProducer.java:34

↓ 1 callersMethodrun

()

src/main/java/amqp/spring/camel/component/SpringAMQPProducer.java:125

↓ 1 callersMethodsetAcknowledgeMode

(String acknowledgeMode)

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:219

↓ 1 callersMethodsetConnectionFactory

(ConnectionFactory connectionFactory)

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:77

↓ 1 callersMethodsetEncoding

(String encoding)

src/main/java/amqp/spring/converter/StringConverter.java:36

↓ 1 callersMethodsetType

(String exchangeType)

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:239

↓ 1 callersMethodsetValue

(String value)

src/test/java/amqp/spring/converter/XStreamConverterTest.java:36

↓ 1 callersMethodsetValue

(String value)

src/test/java/amqp/spring/converter/StringConverterTest.java:33

MethodAMQPProducerTask

(Exchange exchange)

src/main/java/amqp/spring/camel/component/SpringAMQPProducer.java:116

MethodContentTypeConverterFactory

()

src/main/java/amqp/spring/converter/ContentTypeConverterFactory.java:24

MethodHeadersPostProcessor

(org.apache.camel.Message camelMessage)

src/main/java/amqp/spring/camel/component/SpringAMQPMessage.java:91

MethodRabbitMQMessageListener

(SpringAMQPEndpoint endpoint)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:113

MethodSpringAMQPComponent

()

src/main/java/amqp/spring/camel/component/SpringAMQPComponent.java:33

MethodSpringAMQPConsumer

(SpringAMQPEndpoint endpoint, Processor processor)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:54

MethodSpringAMQPEndpoint

(Component component, String uri, String remaining, AmqpTemplate template, AmqpAdmin admin)

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:59

MethodSpringAMQPExecutor

(SpringAMQPEndpoint endpoint)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:277

MethodSpringAMQPExecutorTask

(SpringAMQPEndpoint endpoint, Runnable delegateTask)

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:303

MethodSpringAMQPMessage

()

src/main/java/amqp/spring/camel/component/SpringAMQPMessage.java:23

MethodSpringAMQPProducer

(SpringAMQPEndpoint endpoint)

src/main/java/amqp/spring/camel/component/SpringAMQPProducer.java:29

MethodSynchronousRequestor

(ProducerTemplate template)

src/test/java/amqp/spring/camel/component/ContrivedLoadTest.java:103

MethodXStreamConverter

()

src/main/java/amqp/spring/converter/XStreamConverter.java:39

Methodcall

()

src/test/java/amqp/spring/camel/component/ContrivedLoadTest.java:107

Methodconfigure

()

src/test/java/amqp/spring/camel/component/SpringAMQPConsumerTest.java:207

Methodconfigure

()

src/test/java/amqp/spring/camel/component/SpringAMQPProducerTest.java:106

MethodcopyAMQPHeaders

()

src/test/java/amqp/spring/camel/component/SpringAMQPHeaderTest.java:46

MethodcopyCamelHeaders

()

src/test/java/amqp/spring/camel/component/SpringAMQPHeaderTest.java:58

MethodcreateCamelContext

()

src/test/java/amqp/spring/camel/component/SpringAMQPComponentTest.java:30

MethodcreateCamelContext

()

src/test/java/amqp/spring/camel/component/SpringAMQPConsumerTest.java:190

MethodcreateCamelContext

()

src/test/java/amqp/spring/camel/component/SpringAMQPEndpointTest.java:104

MethodcreateCamelContext

()

src/test/java/amqp/spring/camel/component/SpringAMQPProducerTest.java:91

MethodcreateEndpointUri

()

src/main/java/amqp/spring/camel/component/SpringAMQPEndpoint.java:264

MethodcreateMessage

(Object object, MessageProperties messageProperties)

src/test/java/amqp/spring/camel/component/SpringAMQPMessageTest.java:63

MethodcreateMessage

(Object object, MessageProperties messageProperties)

src/main/java/amqp/spring/converter/StringConverter.java:40

MethodcreateMessage

(Object object, MessageProperties messageProperties)

src/main/java/amqp/spring/converter/XStreamConverter.java:56

MethodcreateMessage

(Object object, MessageProperties messageProperties)

src/main/java/amqp/spring/converter/ContentTypeConverterFactory.java:52

MethodcreateRegistry

()

src/test/java/amqp/spring/camel/component/SpringAMQPConsumerTest.java:183

MethodcreateRouteBuilder

()

src/test/java/amqp/spring/camel/component/SpringAMQPConsumerTest.java:204

MethodcreateRouteBuilder

()

src/test/java/amqp/spring/camel/component/SpringAMQPProducerTest.java:103

MethoddisconnectConsumer

()

src/test/java/amqp/spring/camel/component/SpringAMQPConsumerTest.java:41

MethoddoShutdown

()

src/main/java/amqp/spring/camel/component/SpringAMQPConsumer.java:68

MethoddoShutdown

()

src/main/java/amqp/spring/camel/component/SpringAMQPProducer.java:92

next →1–100 of 195, ranked by callers