List of bindPubSubProducer() Examples

Examples of bindPubSubProducer()

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

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

        MessageDeliveryMode.class);
    assertEquals(MessageDeliveryMode.NON_PERSISTENT, mode);
    verifyFooRequestProducer(endpoint);


    try {
      bus.bindPubSubProducer("dummy", new DirectChannel(), properties);
      fail("Expected exception");
    }
    catch (IllegalArgumentException e) {
      assertThat(e.getMessage(), allOf(
          containsString("RabbitMessageBus does not support producer properties: "),

View Full Code Here

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

    assertFalse(singleNodeApplication.pluginContext().containsBean("topic:y"));
    assertFalse(singleNodeApplication.pluginContext().containsBean("topic:z"));




    DirectChannel testChannel = new DirectChannel();
    bus.bindPubSubProducer("topic:x", testChannel, null);
    testChannel.send(MessageBuilder.withPayload("y").build());
    Thread.sleep(2000);


    singleNodeApplication.pluginContext().getBean("topic:y", MessageChannel.class);
    assertFalse(singleNodeApplication.pluginContext().containsBean("topic:z"));

View Full Code Here

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

    assertEquals(
        "'queue.props.0-' + headers['partition']",
        TestUtils.getPropertyValue(endpoint, "handler.delegate.queueNameExpression", Expression.class).getExpressionString());


    try {
      bus.bindPubSubProducer("dummy", null, properties);
      fail("Expected exception");
    }
    catch (IllegalArgumentException e) {
      assertThat(e.getMessage(), allOf(
          containsString("RedisMessageBus does not support producer 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.