String topic_name = "my_topic";
String type_type = "My_Type";
TopicQos topic_qos = new TopicQos();
TopicListener topic_listener = new MyTopicListener();
participant.get_default_topic_qos(topic_qos);
Topic topic = null;
try {
topic = participant.create_topic(topic_name, type_name,
topic_qos, topic_listener,
StatusKind.STATUS_MASK_ALL);
} catch (RETCODE_ERROR err) {
}