Examples of DiscoveryEvent

io.fabric8.gateway.handlers.detecting.protocol.openwire.command.DiscoveryEvent
Represents a discovery event containing the details of the service @openwire :marshaller code="40" @version $Revision:$
net.jini.discovery.DiscoveryEvent
Event object passed (via either the DiscoveryListener interface or the DiscoveryChangeListener) to indicate to interested parties that one or more ServiceRegistrar objects have been discovered or discarded during the discovery process. @author Sun Microsystems, Inc. @see LookupDiscovery @see LookupLocatorDiscovery @see LookupDiscoveryManager @see DiscoveryListener @see DiscoveryChangeListener @see net.jini.core.lookup.ServiceRegistrar
org.activemq.transport.DiscoveryEvent
Represents a discovery event containing the details of the service @version $Revision: 1.1.1.1 $
org.apache.activemq.apollo.openwire.command.DiscoveryEvent
Represents a discovery event containing the details of the service @openwire :marshaller code="40" @version $Revision:$
org.apache.activemq.command.DiscoveryEvent
Represents a discovery event containing the details of the service @openwire :marshaller code="40"
org.codehaus.activemq.transport.DiscoveryEvent
Represents a discovery event containing the details of the service @version $Revision: 1.1 $

Examples of io.fabric8.gateway.handlers.detecting.protocol.openwire.command.DiscoveryEvent

    
    /**
     * @return a new object instance
     */
    public DataStructure createObject() {
        return new DiscoveryEvent();
    }

View Full Code Here

Examples of net.jini.discovery.DiscoveryEvent


    /** Sends discarded event to each listener waiting for discarded lookups.*/
    private void listenerDropped(ServiceRegistrar[] proxys,ArrayList notifies){
  Iterator iter = notifies.iterator();
  while (iter.hasNext()) {
      DiscoveryEvent evt = new DiscoveryEvent
                                        ( this,
                                          (ServiceRegistrar[])proxys.clone() );
      ((DiscoveryListener)iter.next()).discarded(evt);
  }//end loop
    }//end listenerDropped

View Full Code Here

Examples of net.jini.discovery.DiscoveryEvent


    /** Sends discovered event to each listener listening for new lookups. */
    private void listenerDiscovered(ServiceRegistrar proxy,ArrayList notifies){
  Iterator iter = notifies.iterator();
  while (iter.hasNext()) {
      DiscoveryEvent evt = new DiscoveryEvent
                                        ( this,
                                          new ServiceRegistrar[]{proxy} );
      ((DiscoveryListener)iter.next()).discovered(evt);
  }//end loop
    }//end listenerDiscovered

View Full Code Here

Examples of org.activemq.transport.DiscoveryEvent


    private void fireServiceStarted(ActiveMQObjectMessage message) throws JMSException {
        if (message != null) {
            String name = message.getStringProperty(SERVICE_NAME);
            Map map = (Map) message.getObject();
            DiscoveryEvent event = new DiscoveryEvent(this, name, map);
            fireAddService(event);
        }
    }

View Full Code Here

Examples of org.apache.activemq.apollo.openwire.command.DiscoveryEvent

    
    /**
     * @return a new object instance
     */
    public DataStructure createObject() {
        return new DiscoveryEvent();
    }

View Full Code Here

Examples of org.apache.activemq.apollo.openwire.command.DiscoveryEvent

     * @throws IOException
     */
    public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException {
        super.tightUnmarshal(wireFormat, o, dataIn, bs);


        DiscoveryEvent info = (DiscoveryEvent)o;
        info.setServiceName(tightUnmarshalString(dataIn, bs));
        info.setBrokerName(tightUnmarshalString(dataIn, bs));


    }

View Full Code Here

Examples of org.apache.activemq.apollo.openwire.command.DiscoveryEvent

    /**
     * Write the booleans that this object uses to a BooleanStream
     */
    public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {


        DiscoveryEvent info = (DiscoveryEvent)o;


        int rc = super.tightMarshal1(wireFormat, o, bs);
        rc += tightMarshalString1(info.getServiceName(), bs);
        rc += tightMarshalString1(info.getBrokerName(), bs);


        return rc + 0;
    }

View Full Code Here

Examples of org.apache.activemq.apollo.openwire.command.DiscoveryEvent

     * @throws IOException thrown if an error occurs
     */
    public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException {
        super.tightMarshal2(wireFormat, o, dataOut, bs);


        DiscoveryEvent info = (DiscoveryEvent)o;
        tightMarshalString2(info.getServiceName(), dataOut, bs);
        tightMarshalString2(info.getBrokerName(), dataOut, bs);


    }

View Full Code Here

Examples of org.apache.activemq.apollo.openwire.command.DiscoveryEvent

     * @throws IOException
     */
    public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException {
        super.looseUnmarshal(wireFormat, o, dataIn);


        DiscoveryEvent info = (DiscoveryEvent)o;
        info.setServiceName(looseUnmarshalString(dataIn));
        info.setBrokerName(looseUnmarshalString(dataIn));


    }

View Full Code Here

Examples of org.apache.activemq.apollo.openwire.command.DiscoveryEvent

    /**
     * Write the booleans that this object uses to a BooleanStream
     */
    public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException {


        DiscoveryEvent info = (DiscoveryEvent)o;


        super.looseMarshal(wireFormat, o, dataOut);
        looseMarshalString(info.getServiceName(), dataOut);
        looseMarshalString(info.getBrokerName(), dataOut);


    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.