RTI Connext CORBA Compatibility Kit  Version 6.0.0
 All Groups Pages
MessageDDSPublisher.java

[$(NDDSHOME)/example/JAVA/corba/MessageDDSPublisher.java]

/*
(c) Copyright, Real-Time Innovations, 10/01/2006
All rights reserved.
No duplications, whole or partial, manual or electronic, may be made
without express written permission. Any such copies, or
revisions thereof, must display this notice unaltered.
This code contains trade secrets of Real-Time Innovations, Inc.
===================================================================== */
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Arrays;
import com.rti.dds.domain.*;
import com.rti.dds.infrastructure.*;
import com.rti.dds.publication.*;
import com.rti.dds.topic.*;
import com.rti.ndds.config.*;
// ===========================================================================
public class MessageDDSPublisher {
private DomainParticipant participant = null;
private Publisher publisher = null;
private Topic topic = null;
private MessageDataWriter writer = null;
private int domainId;
// -----------------------------------------------------------------------
// Public Methods
// -----------------------------------------------------------------------
/*
*/
public MessageDDSPublisher(int domainId) {
this.domainId = domainId;
}
/*
*/
public boolean start() {
String typeName;
try {
/* Create participant */
participant = DomainParticipantFactory.TheParticipantFactory.
create_participant(
domainId, DomainParticipantFactory.PARTICIPANT_QOS_DEFAULT,
null /* listener */, StatusKind.STATUS_MASK_NONE);
if (participant == null) {
throw new Exception("Error creating participant");
}
/* Create publisher */
publisher = participant.create_publisher(
DomainParticipant.PUBLISHER_QOS_DEFAULT, null /* listener */,
StatusKind.STATUS_MASK_NONE);
if (publisher == null) {
throw new Exception("Error creating publisher");
}
/* Register type before creating topic */
typeName = MessageTypeSupport.get_type_name();
MessageTypeSupport.register_type(participant, typeName);
/* Create topic */
topic = participant.create_topic(
"Message",
typeName, DomainParticipant.TOPIC_QOS_DEFAULT,
null /* listener */, StatusKind.STATUS_MASK_NONE);
if (topic == null) {
throw new Exception("Error creating topic");
}
/* Create writer */
writer = (MessageDataWriter)
publisher.create_datawriter(
topic, Publisher.DATAWRITER_QOS_DEFAULT,
null /* listener */, StatusKind.STATUS_MASK_NONE);
if (writer == null) {
throw new Exception("Error creating writer");
}
return true;
} catch (Exception e) {
stop();
return false;
}
}
/*
*/
public void stop() {
try {
if(participant != null) {
participant.delete_contained_entities();
writer = null;
topic = null;
publisher = null;
DomainParticipantFactory.TheParticipantFactory.
delete_participant(participant);
participant = null;
}
} catch (Exception e) {
}
}
/*
*/
public boolean publish(Message msg) {
InstanceHandle_t instance_handle = InstanceHandle_t.HANDLE_NIL;
try {
if (writer == null) {
return false;
}
writer.write(msg,instance_handle);
return true;
} catch (Exception e) {
System.out.println(e.getMessage());
return false;
}
}
}

RTI Connext CORBA Compatibility Kit Version 6.0.0 Copyright © Sun Mar 3 2019 Real-Time Innovations, Inc