PublisherQos publisher_qos = new PublisherQos(); // MyPublisherListener is user defined and // extends DDSPublisherListener PublisherListener publisher_listener = new MyPublisherListener(); // or = null participant.get_default_publisher_qos(publisher_qos); Publisher publisher = null; try { publisher = participant.create_publisher(publisher_qos, publisher_listener, StatusKind.STATUS_MASK_ALL); } catch (RETCODE_ERROR err) { // respond to exception }
try { participant.delete_publisher(publisher); } catch (RETCODE_ERROR err) { // respond to exception }