List of bindPubSubConsumer() Examples

Examples of bindPubSubConsumer()

org.springframework.xd.dirt.integration.bus.MessageBus.bindPubSubConsumer()
Bind a message consumer on a pub/sub channel @param name the logical identity of the message source @param inputChannel the channel bound as a pub/sub consumer @param properties arbitrary String key/value pairs that will be used in the binding

Examples of org.springframework.xd.dirt.integration.bus.MessageBus.bindPubSubConsumer()

    container = verifyContainer(endpoint);


    assertEquals("foo.props.0", container.getQueueNames()[0]);


    try {
      bus.bindPubSubConsumer("dummy", null, properties);
      fail("Expected exception");
    }
    catch (IllegalArgumentException e) {
      assertThat(e.getMessage(), allOf(
          containsString("RabbitMessageBus does not support consumer properties: "),

View Full Code Here

Examples of org.springframework.xd.dirt.integration.bus.MessageBus.bindPubSubConsumer()

    MessageChannel z3 = singleNodeApplication.pluginContext().getBean("topic:z", MessageChannel.class);
    assertNotNull(y3);
    assertNotNull(z3);


    QueueChannel consumer = new QueueChannel();
    bus.bindPubSubConsumer("topic:y", consumer, null);
    bus.bindPubSubConsumer("topic:z", consumer, null);
    testChannel.send(MessageBuilder.withPayload("y").build());
    Thread.sleep(2000);
    testChannel.send(MessageBuilder.withPayload("z").build());
    Thread.sleep(2000);

View Full Code Here

Examples of org.springframework.xd.dirt.integration.bus.MessageBus.bindPubSubConsumer()

    assertNotNull(y3);
    assertNotNull(z3);


    QueueChannel consumer = new QueueChannel();
    bus.bindPubSubConsumer("topic:y", consumer, null);
    bus.bindPubSubConsumer("topic:z", consumer, null);
    testChannel.send(MessageBuilder.withPayload("y").build());
    Thread.sleep(2000);
    testChannel.send(MessageBuilder.withPayload("z").build());
    Thread.sleep(2000);
    assertEquals("y", consumer.receive(2000).getPayload());

View Full Code Here

Examples of org.springframework.xd.dirt.integration.bus.MessageBus.bindPubSubConsumer()

    assertEquals(1, bindings.size());
    endpoint = bindings.get(0).getEndpoint();
    verifyConsumer(endpoint);


    try {
      bus.bindPubSubConsumer("dummy", null, properties);
      fail("Expected exception");
    }
    catch (IllegalArgumentException e) {
      assertThat(e.getMessage(), allOf(
          containsString("RedisMessageBus does not support consumer properties: "),

View Full Code Here

TOP

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.