Examples of createProducer()

Examples of com.alu.e3.auth.camel.endpoint.AuthEndpoint.createProducer()

69
70
71
72
73
74
75
76
77
78
79
   * @throws Exception
   */
  @Test
  public void testSuccessHttpBasic() throws Exception{
    AuthEndpoint endpoint = (AuthEndpoint) component.createEndpoint("blah?apiId=1234&basic=true");
    AuthProducer producer = (AuthProducer) endpoint.createProducer();
    Exchange exchange = new DefaultExchange(context);
    // Anything will work for the mock executor... it just has to be set
    exchange.getIn().setHeader(AuthHttpHeaders.Authorization.toString(), "blarg");
   
    producer.process(exchange);
View Full Code Here

Examples of com.consol.citrus.endpoint.Endpoint.createProducer()

94
95
96
97
98
99
100
101
102
103
104
            log.info("Forking send message action ...");

            SimpleAsyncTaskExecutor taskExecutor = new SimpleAsyncTaskExecutor();
            taskExecutor.execute(new Runnable() {
                public void run() {
                    messageEndpoint.createProducer().send(message, context);
                }
            });
        } else {
            messageEndpoint.createProducer().send(message, context);
        }
View Full Code Here

Examples of com.linkedin.databus2.producers.EventProducerServiceProvider.createProducer()

187
188
189
190
191
192
193
194
195
196
197
      EventProducerServiceProvider mockProvider = _producersRegistry.getEventProducerServiceProvider("mock");
      if (null == mockProvider)
      {
        throw new DatabusRuntimeException("relay event producer not available: " + "mock");
      }
      producer = mockProvider.createProducer(pConfig, schemaRegistryService,
                                             dbusEventBuffer,
                                             _inBoundStatsCollectors
                                                     .getStatsCollector(statsCollectorName),
                                             maxScnReaderWriters);
    } else if (uri.startsWith("gg:")){
View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageQueue.createProducer()

516
517
518
519
520
521
522
523
524
525
526
        final int batchSize = 50;

        Executors.newSingleThreadExecutor().execute(new Runnable() {
            @Override
            public void run() {
                MessageProducer producer = scheduler.createProducer();
                for (int i = 0; i < max_count / batchSize; i++) {
                    long tm = System.currentTimeMillis();
                    List<Message> messages = Lists.newArrayList();
                    for (int j = 0; j < batchSize; j++) {
                        long id = insertCount.incrementAndGet();
View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.ShardedDistributedMessageQueue.createProducer()

177
178
179
180
181
182
183
184
185
186
187
                .withPollInterval(100L, TimeUnit.MILLISECONDS)
                .withShardLockManager(slm)
                .build();

        queue.createQueue();
        MessageProducer producer = queue.createProducer();
        MessageConsumer consumer = queue.createConsumer();

        // Enqueue a recurring message
        final String key = "RepeatingMessageWithTimeout";
        final Message message = new Message()
View Full Code Here

Examples of com.taobao.metamorphosis.client.MessageSessionFactory.createProducer()

40
41
42
43
44
45
46
47
48
49
50
public class Producer {
    public static void main(final String[] args) throws Exception {
        // New session factory,ǿ�ҽ���ʹ�õ���
        final MessageSessionFactory sessionFactory = new MetaMessageSessionFactory(initMetaConfig());
        // create producer,ǿ�ҽ���ʹ�õ���
        final MessageProducer producer = sessionFactory.createProducer();
        // publish topic
        final String topic = "meta-test";
        producer.publish(topic);

        final BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
View Full Code Here

Examples of com.taobao.metamorphosis.client.MetaMessageSessionFactory.createProducer()

40
41
42
43
44
45
46
47
48
49
50
public class Producer {
    public static void main(final String[] args) throws Exception {
        // New session factory,ǿ�ҽ���ʹ�õ���
        final MessageSessionFactory sessionFactory = new MetaMessageSessionFactory(initMetaConfig());
        // create producer,ǿ�ҽ���ʹ�õ���
        final MessageProducer producer = sessionFactory.createProducer();
        // publish topic
        final String topic = "meta-test";
        producer.publish(topic);

        final BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
View Full Code Here

Examples of com.taobao.metamorphosis.client.extension.OrderedMessageSessionFactory.createProducer()

54
55
56
57
58
59
60
61
62
63
64
        // New session factory,ǿ�ҽ���ʹ�õ���
        final OrderedMessageSessionFactory sessionFactory = new OrderedMetaMessageSessionFactory(metaClientConfig);

        // create producer,ǿ�ҽ���ʹ�õ���
        final MessageProducer producer = sessionFactory.createProducer(new CustomPartitionSelector());

        // publish topic
        final String topic = "meta-test";
        producer.publish(topic);
View Full Code Here

Examples of com.taobao.metamorphosis.client.extension.OrderedMetaMessageSessionFactory.createProducer()

54
55
56
57
58
59
60
61
62
63
64
        // New session factory,ǿ�ҽ���ʹ�õ���
        final OrderedMessageSessionFactory sessionFactory = new OrderedMetaMessageSessionFactory(metaClientConfig);

        // create producer,ǿ�ҽ���ʹ�õ���
        final MessageProducer producer = sessionFactory.createProducer(new CustomPartitionSelector());

        // publish topic
        final String topic = "meta-test";
        producer.publish(topic);
View Full Code Here

Examples of javax.jms.QueueSession.createProducer()

87
88
89
90
91
92
93
94
95
96
97
      int received = 0;
     
      public void doRun() throws Exception
      {
         QueueSession session = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
         MessageProducer producer = session.createProducer(queue);
         for (int i = 0; i < getIterationCount(); ++i)
         {
            Message message = session.createTextMessage("" + i);
            producer.send(message);
         }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.