Examples of org.springframework.xd.dirt.integration.bus.LocalMessageBus$LocalBusPropertiesAccessor

Package org.springframework.xd.dirt.integration.bus

Examples of org.springframework.xd.dirt.integration.bus.LocalMessageBus$LocalBusPropertiesAccessor

org.springframework.xd.dirt.integration.bus.LocalMessageBus
A simple implementation of {@link MessageBus} for in-process use. For inbound and outbound, creates a{@link DirectChannel} or a {@link QueueChannel} depending on whether the binding is aliased or not then bridges thepassed {@link MessageChannel} to the channel which is registered in the given application context. If that channeldoes not yet exist, it will be created. @author David Turanski @author Mark Fisher @author Gary Russell @author Jennifer Hickey @author Ilayaperumal Gopinathan @since 1.0


  @Bean
  public MessageBus messageBus() {
    PollerMetadata poller = new PollerMetadata();
    poller.setTaskExecutor(taskScheduler());
    LocalMessageBus bus = new LocalMessageBus();
    bus.setPoller(poller);
    return bus;
  }

View Full Code Here

    this.requestsOut = ctx.getBean("stepExecutionRequests.output", MessageChannel.class);
    this.requestsIn = ctx.getBean("stepExecutionRequests.input", MessageChannel.class);
    this.repliesOut = ctx.getBean("stepExecutionReplies.output", MessageChannel.class);
    this.repliesIn = ctx.getBean("stepExecutionReplies.input", MessageChannel.class);


    this.bus = new LocalMessageBus();
    ((LocalMessageBus) this.bus).setApplicationContext(ctx);
    this.bus.bindRequestor("foo", this.requestsOut, this.repliesIn, null);
    this.bus.bindReplier("foo", this.requestsIn, this.repliesOut, null);
  }

View Full Code Here

    file = new FTPFile();
    file.setName("baz.txt");
    fileList[1] = file;
    when(session.list("/foo/")).thenReturn(fileList);


    this.bus = new LocalMessageBus();
    this.bus.setApplicationContext(BusTestUtils.MOCK_AC);
    this.bus.bindRequestor("foo", this.requestsOut, this.repliesIn, null);
    this.bus.bindReplier("foo", this.requestsIn, this.repliesOut, null);
  }

View Full Code Here

TOP

Related Classes of org.springframework.xd.dirt.integration.bus.LocalMessageBus$LocalBusPropertiesAccessor

org.springframework.batch.integration.x.RemoteFileToHadoopTests

org.springframework.batch.integration.x.RemoteFileToTmpTests

org.springframework.integration.channel.ExecutorChannel

org.springframework.integration.config.ConsumerEndpointFactoryBean

org.springframework.integration.handler.BridgeHandler

org.springframework.messaging.MessageChannel

org.springframework.messaging.MessageHandler

org.springframework.messaging.SubscribableChannel

org.springframework.xd.dirt.rest.Dependencies

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.