try {

			String Cid = MqttClient.generateClientId();
 			MqttClient mqttClient = new MqttClient(BROKER_URI, Cid, new MemoryPersistence());
			mqttClient.setCallback(new MqttCallback() {

				@Override
				public void messageArrived(String topic, MqttMessage message) throws Exception {

					try {

						System.out.println(topic + "--" + new String(message.getPayload()));

					} catch (RuntimeException e) {
						e.printStackTrace();
					}
				}

				@Override
				public void deliveryComplete(IMqttDeliveryToken token) {
					// not used
				}

				@Override
				public void connectionLost(Throwable cause) {
					System.out.println("Connection lost: " +         cause.getLocalizedMessage());
				}
			});
	        MqttConnectOptions connOpt = new MqttConnectOptions();
		 connOpt.setCleanSession(true);
		 connOpt.setKeepAliveInterval(30);
		 connOpt.setUserName("NCU102552018_broker");
		 connOpt.setPassword("********".toCharArray());
		 mqttClient.connect(connOpt);
		 mqttClient.subscribe("$EDC/NCU102552018/Kura_1/CONF-V1/#");
		 
		} catch (MqttException e) {
			e.printStackTrace();
		}