Examples of MessageEvent

  • jetbrains.communicator.core.transport.MessageEvent
    @author kir
  • net.gleamynode.netty.channel.MessageEvent
  • net.sourceforge.processdash.msg.MessageEvent
  • org.cspoker.common.api.chat.event.MessageEvent
  • org.directwebremoting.event.MessageEvent
    An MessageEvent is fired to a set of {@link MessageListener}s by the DWR {@link Hub}. @author Joe Walker [joe at getahead dot ltd dot uk]
  • org.eclipse.ecf.internal.provider.xmpp.events.MessageEvent
  • org.groovymud.engine.event.messages.MessageEvent
  • org.gwtoolbox.sample.ioc.client.event.MessageEvent
    @author Uri Boness
  • org.jboss.netty.channel.MessageEvent
    @author The Netty Project (netty-dev@lists.jboss.org) @author Trustin Lee (tlee@redhat.com) @version $Rev: 6 $, $Date: 2008-08-08 10:40:10 +0900 (Fri, 08 Aug 2008) $
  • org.jivesoftware.smackx.packet.MessageEvent
    Represents message events relating to the delivery, display, composition and cancellation of messages.

    There are four message events currently defined in this namespace:

    1. Offline
      Indicates that the message has been stored offline by the intended recipient's server. This event is triggered only if the intended recipient's server supports offline storage, has that support enabled, and the recipient is offline when the server receives the message for delivery.
    2. Delivered
      Indicates that the message has been delivered to the recipient. This signifies that the message has reached the recipient's XMPP client, but does not necessarily mean that the message has been displayed. This event is to be raised by the XMPP client.
    3. Displayed
      Once the message has been received by the recipient's XMPP client, it may be displayed to the user. This event indicates that the message has been displayed, and is to be raised by the XMPP client. Even if a message is displayed multiple times, this event should be raised only once.
    4. Composing
      In threaded chat conversations, this indicates that the recipient is composing a reply to a message. The event is to be raised by the recipient's XMPP client. A XMPP client is allowed to raise this event multiple times in response to the same request, providing the original event is cancelled first.
    @author Gaston Dombiak
  • org.netbeans.lib.cvsclient.event.MessageEvent
  • org.pircbotx.hooks.events.MessageEvent
  • org.rsbot.event.events.MessageEvent
    A message event.
  • robocode.MessageEvent
    A MessageEvent is sent to {@link TeamRobot#onMessageReceived(MessageEvent) onMessageReceived()} when a teammate sends a message to your robot.You can use the information contained in this event to determine what to do. @author Mathew A. Nelson (original)
  • rocks.xmpp.core.stanza.MessageEvent
    A message event is fired whenever a message is received or sent. @author Christian Schudt @see MessageListener

  • Examples of clueless.events.MessageEvent

       
          /** Keep listening for messages from the server */
             while(keepRunning && clientSocket.isConnected()) {
              
               /** Pass received messages to the controller */
              controller.fireMessageEvent(new MessageEvent(this, receive()));

             }
      }
    View Full Code Here

    Examples of com.facebook.presto.jdbc.internal.netty.channel.MessageEvent

            if (!(evt instanceof MessageEvent)) {
                ctx.sendDownstream(evt);
                return;
            }

            final MessageEvent e = (MessageEvent) evt;
            Object msg = e.getMessage();

            if (msg instanceof SpdyDataFrame) {

                SpdyDataFrame spdyDataFrame = (SpdyDataFrame) msg;
                ChannelBuffer data = spdyDataFrame.getData();
                byte flags = spdyDataFrame.isLast() ? SPDY_DATA_FLAG_FIN : 0;
                ChannelBuffer header = ChannelBuffers.buffer(
                        ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE);
                header.writeInt(spdyDataFrame.getStreamId() & 0x7FFFFFFF);
                header.writeByte(flags);
                header.writeMedium(data.readableBytes());
                ChannelBuffer frame = ChannelBuffers.wrappedBuffer(header, data);
                Channels.write(ctx, e.getFuture(), frame, e.getRemoteAddress());
                return;
            }

            if (msg instanceof SpdySynStreamFrame) {

                synchronized (headerBlockEncoder) {
                    SpdySynStreamFrame spdySynStreamFrame = (SpdySynStreamFrame) msg;
                    ChannelBuffer data = headerBlockEncoder.encode(spdySynStreamFrame);
                    byte flags = spdySynStreamFrame.isLast() ? SPDY_FLAG_FIN : 0;
                    if (spdySynStreamFrame.isUnidirectional()) {
                        flags |= SPDY_FLAG_UNIDIRECTIONAL;
                    }
                    int headerBlockLength = data.readableBytes();
                    int length;
                    if (version < 3) {
                        length = headerBlockLength == 0 ? 12 : 10 + headerBlockLength;
                    } else {
                        length = 10 + headerBlockLength;
                    }
                    ChannelBuffer frame = ChannelBuffers.buffer(
                            ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + 12);
                    frame.writeShort(version | 0x8000);
                    frame.writeShort(SPDY_SYN_STREAM_FRAME);
                    frame.writeByte(flags);
                    frame.writeMedium(length);
                    frame.writeInt(spdySynStreamFrame.getStreamId());
                    frame.writeInt(spdySynStreamFrame.getAssociatedToStreamId());
                    if (version < 3) {
                        // Restrict priorities for SPDY/2 to between 0 and 3
                        byte priority = spdySynStreamFrame.getPriority();
                        if (priority > 3) {
                            priority = 3;
                        }
                        frame.writeShort((priority & 0xFF) << 14);
                    } else {
                        frame.writeShort((spdySynStreamFrame.getPriority() & 0xFF) << 13);
                    }
                    if (version < 3 && data.readableBytes() == 0) {
                        frame.writeShort(0);
                    }
                    // Writes of compressed data must occur in order
                    final ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(frame, data);
                    Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
                }
                return;
            }

            if (msg instanceof SpdySynReplyFrame) {

                synchronized (headerBlockEncoder) {
                    SpdySynReplyFrame spdySynReplyFrame = (SpdySynReplyFrame) msg;
                    ChannelBuffer data = headerBlockEncoder.encode(spdySynReplyFrame);
                    byte flags = spdySynReplyFrame.isLast() ? SPDY_FLAG_FIN : 0;
                    int headerBlockLength = data.readableBytes();
                    int length;
                    if (version < 3) {
                        length = headerBlockLength == 0 ? 8 : 6 + headerBlockLength;
                    } else {
                        length = 4 + headerBlockLength;
                    }
                    ChannelBuffer frame = ChannelBuffers.buffer(
                            ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + 8);
                    frame.writeShort(version | 0x8000);
                    frame.writeShort(SPDY_SYN_REPLY_FRAME);
                    frame.writeByte(flags);
                    frame.writeMedium(length);
                    frame.writeInt(spdySynReplyFrame.getStreamId());
                    if (version < 3) {
                        if (data.readableBytes() == 0) {
                            frame.writeInt(0);
                        } else {
                            frame.writeShort(0);
                        }
                    }
                    // Writes of compressed data must occur in order
                    final ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(frame, data);
                    Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
                }
                return;
            }

            if (msg instanceof SpdyRstStreamFrame) {

                SpdyRstStreamFrame spdyRstStreamFrame = (SpdyRstStreamFrame) msg;
                ChannelBuffer frame = ChannelBuffers.buffer(
                        ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + 8);
                frame.writeShort(version | 0x8000);
                frame.writeShort(SPDY_RST_STREAM_FRAME);
                frame.writeInt(8);
                frame.writeInt(spdyRstStreamFrame.getStreamId());
                frame.writeInt(spdyRstStreamFrame.getStatus().getCode());
                Channels.write(ctx, e.getFuture(), frame, e.getRemoteAddress());
                return;
            }

            if (msg instanceof SpdySettingsFrame) {

                SpdySettingsFrame spdySettingsFrame = (SpdySettingsFrame) msg;
                byte flags = spdySettingsFrame.clearPreviouslyPersistedSettings() ?
                    SPDY_SETTINGS_CLEAR : 0;
                Set<Integer> IDs = spdySettingsFrame.getIds();
                int numEntries = IDs.size();
                int length = 4 + numEntries * 8;
                ChannelBuffer frame = ChannelBuffers.buffer(
                        ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + length);
                frame.writeShort(version | 0x8000);
                frame.writeShort(SPDY_SETTINGS_FRAME);
                frame.writeByte(flags);
                frame.writeMedium(length);
                frame.writeInt(numEntries);
                for (Integer ID: IDs) {
                    int id = ID.intValue();
                    byte ID_flags = 0;
                    if (spdySettingsFrame.isPersistValue(id)) {
                        ID_flags |= SPDY_SETTINGS_PERSIST_VALUE;
                    }
                    if (spdySettingsFrame.isPersisted(id)) {
                        ID_flags |= SPDY_SETTINGS_PERSISTED;
                    }
                    if (version < 3) {
                        // Chromium Issue 79156
                        // SPDY setting ids are not written in network byte order
                        // Write id assuming the architecture is little endian
                        frame.writeByte(id & 0xFF);
                        frame.writeByte(id >>  8 & 0xFF);
                        frame.writeByte(id >> 16 & 0xFF);
                        frame.writeByte(ID_flags);
                    } else {
                        frame.writeByte(ID_flags);
                        frame.writeMedium(id);
                    }
                    frame.writeInt(spdySettingsFrame.getValue(id));
                }
                Channels.write(ctx, e.getFuture(), frame, e.getRemoteAddress());
                return;
            }

            if (msg instanceof SpdyPingFrame) {

                SpdyPingFrame spdyPingFrame = (SpdyPingFrame) msg;
                ChannelBuffer frame = ChannelBuffers.buffer(
                        ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + 4);
                frame.writeShort(version | 0x8000);
                frame.writeShort(SPDY_PING_FRAME);
                frame.writeInt(4);
                frame.writeInt(spdyPingFrame.getId());
                Channels.write(ctx, e.getFuture(), frame, e.getRemoteAddress());
                return;
            }

            if (msg instanceof SpdyGoAwayFrame) {

                SpdyGoAwayFrame spdyGoAwayFrame = (SpdyGoAwayFrame) msg;
                int length = version < 3 ? 4 : 8;
                ChannelBuffer frame = ChannelBuffers.buffer(
                        ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + length);
                frame.writeShort(version | 0x8000);
                frame.writeShort(SPDY_GOAWAY_FRAME);
                frame.writeInt(length);
                frame.writeInt(spdyGoAwayFrame.getLastGoodStreamId());
                if (version >= 3) {
                    frame.writeInt(spdyGoAwayFrame.getStatus().getCode());
                }
                Channels.write(ctx, e.getFuture(), frame, e.getRemoteAddress());
                return;
            }

            if (msg instanceof SpdyHeadersFrame) {

                synchronized (headerBlockEncoder) {
                    SpdyHeadersFrame spdyHeadersFrame = (SpdyHeadersFrame) msg;
                    ChannelBuffer data = headerBlockEncoder.encode(spdyHeadersFrame);
                    byte flags = spdyHeadersFrame.isLast() ? SPDY_FLAG_FIN : 0;
                    int headerBlockLength = data.readableBytes();
                    int length;
                    if (version < 3) {
                        length = headerBlockLength == 0 ? 4 : 6 + headerBlockLength;
                    } else {
                        length = 4 + headerBlockLength;
                    }
                    ChannelBuffer frame = ChannelBuffers.buffer(
                            ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + length);
                    frame.writeShort(version | 0x8000);
                    frame.writeShort(SPDY_HEADERS_FRAME);
                    frame.writeByte(flags);
                    frame.writeMedium(length);
                    frame.writeInt(spdyHeadersFrame.getStreamId());
                    if (version < 3 && data.readableBytes() != 0) {
                        frame.writeShort(0);
                    }
                    // Writes of compressed data must occur in order
                    final ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(frame, data);
                    Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
                }
                return;
            }

            if (msg instanceof SpdyWindowUpdateFrame) {
                SpdyWindowUpdateFrame spdyWindowUpdateFrame = (SpdyWindowUpdateFrame) msg;
                ChannelBuffer frame = ChannelBuffers.buffer(
                        ByteOrder.BIG_ENDIAN, SPDY_HEADER_SIZE + 8);
                frame.writeShort(version | 0x8000);
                frame.writeShort(SPDY_WINDOW_UPDATE_FRAME);
                frame.writeInt(8);
                frame.writeInt(spdyWindowUpdateFrame.getStreamId());
                frame.writeInt(spdyWindowUpdateFrame.getDeltaWindowSize());
                Channels.write(ctx, e.getFuture(), frame, e.getRemoteAddress());
                return;
            }

            // Unknown message type
            ctx.sendDownstream(evt);
    View Full Code Here

    Examples of com.flashdoctors.eclipse.logconsole.server.event.MessageEvent

          object = ((JSONArray) object);
        }

        logMessage.setMessageObject(object);

        final MessageEvent event = new MessageEvent();
        event.setMessage(logMessage);
        Display.getDefault().asyncExec(new Runnable()
        {
          public void run()
          {
            eventPublisher.publishEvent(event);
    View Full Code Here

    Examples of com.qq.weixin.sdk.message.MessageEvent

        return filterChain.doFilterChain(message);
      }

      @Override
      protected void parseSpecialMessage(Message message, Element root) {
        MessageEvent messageEvent = (MessageEvent) message;
        messageEvent.setEvent(root.getElementsByTagName(TAG_EVENT).item(0).getTextContent());
        messageEvent.setEventKey(root.getElementsByTagName(TAG_EVENTKEY).item(0).getTextContent());
      }
    View Full Code Here

    Examples of de.bamberg.ha.api.remote.MessageEvent

        });
      }

      @Test
      public void test() {
        MessageEvent event=new MessageEvent("Hello World!");
        processEvent(event);
      }
    View Full Code Here

    Examples of edu.csusm.cs671.auction.sockets.client.MessageEvent

        auctionMessage.setAuctionID(UUID.randomUUID());
        //auctionMessage.setTimeAuctionIsOpen(new Duration(10));
        auctionMessage.setWorkForAuction(work);
       
       
        MessageEvent messageEvent = new MessageEvent(auctionAgent, auctionMessage);
        auctionAgent.onMessageReceived(messageEvent);
       
       
      }
    View Full Code Here

    Examples of io.netty.channel.MessageEvent

                }

                List<MessageEvent> pendingWrites = new ArrayList<MessageEvent>();
                synchronized (this) {
                    for (;;) {
                        MessageEvent e = queue.poll();
                        if (e == null) {
                            break;
                        }
                        if (!(e.getMessage() instanceof ChannelBuffer)) {
                            if ((pendingWrites = consolidatedWrite(pendingWrites)) == null) {
                                pendingWrites = new ArrayList<MessageEvent>();
                            }
                            ctx.sendDownstream(e);
                        } else {
                            pendingWrites.add(e);
                        }
                    }
                    consolidatedWrite(pendingWrites);
                }
            } else {
                synchronized (this) {
                    for (;;) {
                        MessageEvent e = queue.poll();
                        if (e == null) {
                            break;
                        }
                        ctx.sendDownstream(e);
                    }
    View Full Code Here

    Examples of io.netty.channel.MessageEvent

                }

            } else if (e instanceof MessageEvent) {

                final MessageEvent event = (MessageEvent) e;
                if (event.getMessage() instanceof ChannelBuffer) {
                    executor.execute(
                            new WriteRunnable((DefaultChannelFuture) future, this, (ChannelBuffer) event.getMessage())
                    );
                } else {
                    throw new IllegalArgumentException(
                            "Only ChannelBuffer objects are supported to be written onto the RXTXChannelSink! "
                                    + "Please check if the encoder pipeline is configured correctly."
    View Full Code Here

    Examples of io.netty.channel.MessageEvent

            if (getLogger().isEnabled(level)) {
                String msg = e.toString();

                // Append hex dump if necessary.
                if (hexDump && e instanceof MessageEvent) {
                    MessageEvent me = (MessageEvent) e;
                    if (me.getMessage() instanceof ChannelBuffer) {
                        ChannelBuffer buf = (ChannelBuffer) me.getMessage();
                        msg = msg + " - (HEXDUMP: " + hexDump(buf) + ')';
                    }
                }

                // Log the message (and exception if available.)
    View Full Code Here

    Examples of irc4j.event.MessageEvent

                for (int i = 3; i<raw.size(); i++) {
                    builder.append(raw.get(i)).append(" ");
                }
                System.out.println("NOTICE FROM " + raw.get(0) + ": " + builder.toString());
            } else if (raw.get(1).equals("PRIVMSG")) {
                MessageEvent event = new MessageEvent(this, raw.get(0), raw.get(2), raw.get(3));
                listener.onMessageEvent(event);
            }
            if (connectionReady || !hasConnected) {
                listener.onConnectEvent(new ConnectEvent(this));
                this.connectionReady = false;
    View Full Code Here
    TOP
    Copyright © 2018 www.massapi.com. All rights reserved.
    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.