I tried in cluster as well .
On Wed, Mar 14, 2018 at 10:01 PM, Timo Walther <twal...@apache.org> wrote:
> Hi Puneet,
>
> are you running this job on the cluster or locally in your IDE?
>
> Regards,
> Timo
>
>
> Am 14.03.18 um 13:49 schrieb Puneet Kinra:
>
> Hi
>
> I used apache bahir connector below is the code.the job is getting
> finished
> and not generated the output as well ,ideal it should keep on running
> below the code.
>
>
> import org.apache.activemq.ActiveMQConnectionFactory;
> import org.apache.flink.streaming.api.datastream.DataStream;
> import org.apache.flink.streaming.api.environment.
> StreamExecutionEnvironment;
> import org.apache.flink.streaming.connectors.activemq.AMQSource;
> import org.apache.flink.streaming.connectors.activemq.AMQSourceConfig;
> import org.apache.flink.streaming.connectors.activemq.DestinationType;
> import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
>
> /**
> * @author puneet
> *
> */
> public class TestAMQ {
>
>
> public static void main(String[] args) throws Exception {
> StreamExecutionEnvironment env = StreamExecutionEnvironment.
> getExecutionEnvironment();
> AMQSourceConfig<String> sourceConfig = new AMQSourceConfig.
> AMQSourceConfigBuilder<String>()
> .setConnectionFactory(new ActiveMQConnectionFactory("
> tcp://localhost:61616"))
> .setDestinationName("test")
> .setDeserializationSchema(new SimpleStringSchema())
> .setDestinationType(DestinationType.QUEUE)
> .build();
> DataStream < String > messageStream = env.addSource(new AMQSource<String>(
> sourceConfig));
> messageStream.print();
> env.execute();
> }
>
> }
>
>
> --
> *Cheers *
>
> *Puneet Kinra*
>
> *Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com
> <puneet.ki...@customercentria.com>*
>
> *e-mail :puneet.ki...@customercentria.com
> <puneet.ki...@customercentria.com>*
>
>
>
>
--
*Cheers *
*Puneet Kinra*
*Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com
<puneet.ki...@customercentria.com>*
*e-mail :puneet.ki...@customercentria.com
<puneet.ki...@customercentria.com>*
