Hi, How can we specify the addConfiguration values that can be used in custom scheduling under flux ?
For example: I have a custom scheduler that implements IScheduler. I have the below under my Topology.java: TopologyBuilder builder = new TopologyBuilder(); builder.setSpout( "Source_data_amqtest", new MessagingQueueSource() ).addConfiguration( "group", 4 ); How can i specify this addConfiguration( "group", 4 ) for a spout in Flux ? Regards, Rajeev.
