Jump to content
OpenSplice DDS Forum

Search the Community

Showing results for tags 'Java'.

More search options

  • Search By Tags

    Type tags separated by commas.
  • Search By Author

Content Type


  • About OpenSplice DDS
    • News and Events
    • Site Feedback
  • Using OpenSplice DDS
    • General
    • Troubleshooting
  • Understanding OpenSplice DDS
    • OpenSplice DDS Slideshows
    • OpenSplice DDS Movies
  • Community
    • Project: SIMD
    • Project: CamelOS
    • Project: DDS Touchstone
    • Project: RESTful DDS
    • Mac OS X


  • Community Calendar

Found 7 results

  1. Hi all! In my application I require that the just created DataReader(s) with a listener attached (that for the moment, has only the method on_data_available implemented), do not automatically read the samples that were previously written by a DataWriter (because I have to implement a dedicated procedure for doing it). What is the best solution for accomplish it ? Thanks in advance for every answer I will receive, Regards G.
  2. Hi all, I am building an OpenSplice application, and I created the IDL topic I need. Into that, I have to use some sequence, that the pre-processor convert as array. Bi the way, at the moment, I cant figure out which the best solution for adding/removing elements from this sequence is. Is there an already implemented solutions in IDL ? Shall I create separately in my codes these ? Thank you all in advance. Best regards.
  3. Hello All, I have created the normal publishers and subscribers implemented using java , which works as reading the contents by size as 1MB of total size 5MB and published on every 1MB to the subscriber.Data is getting published successfully .Now 'm facing the issue on appending the content to the existing file .Finally i could find only the last 1MB of data in the file.So please let me to know how to solve this issue ? and also i have attached the source code for publisher and subscriber. Thanks in advance Publisher.txt Subscriber.txt
  4. Subscriber QoS Policy

    Hello All, Please help me configure QoS to implement the following, I am having one publisher and many subscribers, from the subscriber side i want to receive the same content only one time. That is, publisher publishing content1,content2 Subscriber receiving content1,content2 and it will end. Again publisher publishing content3 Normally subscriber again starts receiving from content1,content2,content3 I want to configure subscriber who are all receiving the contents they should not be receiving the same content next time, that is from above example, the subscriber should be receive content3 alone in second run. How to configure the QoS to achieve this ?? Thanks -Viswa
  5. Message Instance and Samples

    Hello All, I am trying to publish the sequence of messages in the topic. I can publish it successfully but i trying to subscribe the messages i am getting last message which i was published. Note I have used HelloWorld: DDSEntityManager.java from the example. Publisher Code: public static void messagePublisher(String devMessage,String devMessageType, String devDeviceSerialType,String devAction ) { SimpleDDS mgr = new SimpleDDS(); String partitionName = "MessageService"; mgr.createParticipant(partitionName); DDSMessageTypeSupport msgTS = new DDSMessageTypeSupport(); mgr.registerType(msgTS); mgr.createTopic("Messages"); mgr.createPublisher(); mgr.createWriter(); DataWriter dwriter = mgr.getWriter(); DDSMessageDataWriter ddsWriter = DDSMessageDataWriterHelper.narrow(dwriter); DDSMessage msgInstance = new DDSMessage(devDeviceSerialType, devMessageType, devAction, devMessage); ddsWriter.register_instance(msgInstance); int status = ddsWriter.write(msgInstance, HANDLE_NIL.value); ErrorHandler.checkStatus(status, "DDSMessageDataWriter.write"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } mgr.getPublisher().delete_datawriter(ddsWriter); mgr.deletePublisher(); mgr.deleteTopic(); mgr.deleteParticipant(); try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } } public static void main(String[] args) { messagePublisher("112-2134354","response","XMLMessage","123"); messagePublisher("112-2134354","response","XMLMessage","1234"); messagePublisher("230-4353456","response","XMLMessage","12345"); } Subscriber Code: public static void messageSubscriber(String args) { SimpleDDS mgr = new SimpleDDS(); String partitionName = "MessageService"; mgr.createParticipant(partitionName); DDSMessageTypeSupport msgTS = new DDSMessageTypeSupport(); mgr.registerType(msgTS); mgr.createTopic("Messages"); mgr.createSubscriber(); mgr.createReader(); DataReader dreader = mgr.getReader(); DDSMessageDataReader ddsReader = DDSMessageDataReaderHelper.narrow(dreader); DDSMessageSeqHolder msgSeq = new DDSMessageSeqHolder(); SampleInfoSeqHolder infoSeq = new SampleInfoSeqHolder(); boolean terminate = false; int count = 0; while (!terminate && count < 1500) { ddsReader.take(msgSeq, infoSeq, LENGTH_UNLIMITED.value, ANY_SAMPLE_STATE.value, ANY_VIEW_STATE.value, ANY_INSTANCE_STATE.value); System.out.println(msgSeq.value.length); for (int i = 0; i < msgSeq.value.length; i++) { System.out.println(" userID : " + msgSeq.value[i].deviceSerialType); System.out.println(" type : " + msgSeq.value[i].messageType); System.out.println(" action : " + msgSeq.value[i].actionType); System.out.print(" Message : \"" + msgSeq.value[i].message + "\""); //terminate = true; } try { Thread.sleep(200); } catch(InterruptedException ie) { // nothing to do } ++count; } ddsReader.return_loan(msgSeq, infoSeq); mgr.getSubscriber().delete_datareader(ddsReader); mgr.deleteSubscriber(); mgr.deleteTopic(); mgr.deleteParticipant(); } public static void main(String[] args) { messageSubscriber("test"); } But Subscriber resulting last message which is published. Please help me. userID : XMLMessage type : response action : 12345 Message : "230-4353456" Thanks -Viswa
  6. Hello All, I am working in Linux platform ,implementing Opensplice DDS with Java using Eclipse as IDE. Publishesr and Subscribers of main classes are getting executed .Currently working in code coverage part using the tool EMMA .I have created the build file using ant script and created the targets for EMMA,At present 'm facing issue as mentioned below, This is the content at console: [emmajava] # A fatal error has been detected by the Java Runtime Environment: [emmajava] # [emmajava] # SIGSEGV (0xb) at pc=0x00f3a97a, pid=3580, tid=2472213360 [emmajava] # [emmajava] # JRE version: 6.0_20-b20 [emmajava] # Java VM: OpenJDK Client VM (19.0-b06 mixed mode linux-x86 ) [emmajava] # Derivative: IcedTea6 1.9.1 [emmajava] # Distribution: Custom build (Wed Oct 13 22:53:35 UTC 2010) [emmajava] # Problematic frame: [emmajava] # V [libjvm.so+0x20b97a] [emmajava] # [emmajava] # An error report file with more information is saved : hs_err_pid3580.log The error report is been attached..I would like to know is ,how to use the Opensplice DDS with EMMA coverage ?Should i wanna change any of the configurations ?Finally is it possible to make code coverage in DDS implementation ? If any body else is aware about this issue, please guide me to proceed it..Thanks in advance... hs_err_pid3580.log.txt
  7. Executing Java Files

    Hello All, I am using java for Open splice DDS Implementation . I have created the JAR file and getting executed. Now i need to execute the main class file independently .Once started executing it, i could face some issue in the create participant() .Could some one guide me to solve this issue. Thanks in advance.. Sample Exception Codes: org.opensplice.dds.dcps.DomainParticipantFactoryImpl.get_instance() failed: org.opensplice.dds.dcps.DomainParticipantFactoryImpl.jniGetInstance()Lorg/opensplice/dds/dcps/DomainParticipantFactoryImpl; Exception in thread "main" java.lang.NullPointerException at DDS.DomainParticipantFactory.create_participant(Unknown Source) at com.covidien.laptopagent.dds.publisher.DDSEntityManager.createParticipant(DDSEntityManager.java:49) at com.covidien.laptopagent.dds.publisher.MessageDataPublisher.towriteDDS(MessageDataPublisher.java:72) at com.covidien.laptopagent.dds.publisher.MessageDataPublisher.main(MessageDataPublisher.java:56)