Examples of com.sun.sgs.app.Channel

com.sun.sgs.app.Channel
Interface representing a communication group, a {@code Channel}, consisting of multiple client sessions. Classes that implement {@code Channel} must also implement {@link Serializable}.
A channel is created by invoking the {@link ChannelManager#createChannel ChannelManager.createChannel} method with aname, a {@code ChannelListener}, and a {@link Delivery} guarantee. A{@link ClientSession} can be added or removed from a channel using that{@code Channel}'s {@link #join(ClientSession) join} and {@link #leave(ClientSession) leave} methods respectively. All client sessionscan be removed from a channel by invoking {@link #leaveAll leaveAll} onthe channel. To explicitly close a {@code Channel}, remove the {@code Channel} object from the data manager using the {@link DataManager#removeObject DataManager.removeObject} method.
The server can send a message to all client sessions joined to a channel by using the {@link #send send} method. Note that the methodsof this interface are invoked within the context of an executing {@link Task}; as a result, a message sent to client sessions using the {@code send} method will not be sent until after its corresponding taskcompletes.
Messages sent on a channel are delivered in a manner that satisfies the channel's delivery guarantee, specified at creation time. When possible, channel messages are delivered using the most efficient means to satisfy the delivery guarantee. However, a stronger delivery guarantee may be used to deliver the message if the underlying protocol only supports stronger delivery guarantees. A client session can not be joined to a channel if that client session does not support a protocol satisfying the minimum requirements of the channel's delivery guarantee.
A client session joined to one or more channels may become disconnected due to the client logging out or due to other factors such as forced disconnection or network failure. If a client session becomes disconnected, then that client session is removed from each channel that it is a member of.
When the application is finished using a channel, the application should remove the channel from the data manager, which closes the channel and releases all resources associated with the channel. @see ChannelManager#createChannel ChannelManager.createChannel

    }


    protected void leaveAll(final String channelName) throws Exception {
  txnScheduler.runTask(new TestAbstractKernelRunnable() {
      public void run() {
    Channel channel = getChannel(channelName);
    channel.leaveAll();
      }
  }, taskOwner);
    }

View Full Code Here

  final String channelName, final String... users)
  throws Exception
    {
  txnScheduler.runTask(new TestAbstractKernelRunnable() {
      public void run() {
    Channel channel = getChannel(channelName);
    Set<ClientSession> sessions = getSessions(channel);
    System.err.println("Sessions joined:" + sessions);
    if (sessions.size() != users.length) {
        fail("Expected " + users.length + " sessions, got " +
       sessions.size());

View Full Code Here

             HexDumper.format(buf.getBuffer()));
      
      txnScheduler.runTask(
    new TestAbstractKernelRunnable() {
        public void run() {
      Channel channel = getChannel(channelName);
      channel.send(null, ByteBuffer.wrap(buf.getBuffer()));
        }
    }, taskOwner);
  }
    }

View Full Code Here

  throws Exception
    {
  return KernelCallable.call(
      new KernelCallable<BigInteger>("getChannelId") {
    public BigInteger call() throws Exception {
    Channel channel =
        AppContext.getChannelManager().getChannel(channelName);
    Field field = getField(channel.getClass(), "channelRef");
    ManagedReference channelRef =
        (ManagedReference) field.get(channel);
    return channelRef.getId();
    }
      }, txnScheduler, taskOwner);

View Full Code Here

         ChannelListener listener,
         Delivery delivery)
    {
        serviceStats.createChannelOp.report();
  try {
      Channel channel = ChannelImpl.newInstance(
    name, listener, delivery, writeBufferSize);
      return channel;
      
  } catch (RuntimeException e) {
      logger.logThrow(Level.FINEST, e, "createChannel:{0} throws");

View Full Code Here

  void checkMembership(final String name, final boolean isMember)
      throws Exception
  {
      txnScheduler.runTask(new TestAbstractKernelRunnable() {
    public void run() {
        Channel channel = getChannel(name);
        Set<ClientSession> sessions = getSessions(channel);
        for (DummyClient client : clients.values()) {


      ClientSession session = getClientSession(client.name);

View Full Code Here


    @Test
    public void testChannelWriteReadObject() throws Exception {
  txnScheduler.runTask(new TestAbstractKernelRunnable() {
      public void run() throws Exception {
    Channel savedChannel =
        channelService.createChannel("x", null, Delivery.RELIABLE);
    ByteArrayOutputStream bout = new ByteArrayOutputStream();
    ObjectOutputStream out = new ObjectOutputStream(bout);
    out.writeObject(savedChannel);
    out.flush();
    out.close();
    
    ByteArrayInputStream bin =
        new ByteArrayInputStream(bout.toByteArray());
    ObjectInputStream in = new ObjectInputStream(bin);
    Channel channel = (Channel) in.readObject();


    if (!savedChannel.equals(channel)) {
        fail("Expected channel: " + savedChannel +
       ", got " + channel);
    }

View Full Code Here

    
    // -- Test Channel.getName --


    @Test
    public void testChannelGetNameNoTxn() throws Exception {
  Channel channel = createChannel();
  try {
      channel.getName();
      fail("Expected TransactionNotActiveException");
  } catch (TransactionNotActiveException e) {
      System.err.println(e);
  }
    }

View Full Code Here

  }
    }


    @Test
    public void testChannelGetNameMismatchedTxn() throws Exception {
  final Channel channel = createChannel();
  txnScheduler.runTask(new TestAbstractKernelRunnable() {
      public void run() {
    try {
        channel.getName();
        fail("Expected TransactionNotActiveException");
    } catch (TransactionNotActiveException e) {
        System.err.println(e);
    }
      }

View Full Code Here

    @Test
    public void testChannelGetName() throws Exception {
  txnScheduler.runTask(new TestAbstractKernelRunnable() {
      public void run() {
    String name = "foo";
    Channel channel = channelService.createChannel(
        name, null, Delivery.RELIABLE);
    if (!name.equals(channel.getName())) {
        fail("Expected: " + name + ", got: " + channel.getName());
    }
      }
  }, taskOwner);
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.sun.sgs.app.Channel

com.sun.sgs.impl.service.channel.ChannelServiceImpl

com.sun.sgs.test.impl.service.channel.AbstractChannelServiceTest

com.sun.sgs.test.impl.service.channel.AbstractChannelServiceTest$ClientGroup

com.sun.sgs.test.impl.service.channel.AbstractChannelServiceTest$DummyClientSessionListener

com.sun.sgs.test.impl.service.channel.TestChannelServiceImpl

com.sun.sgs.tutorial.server.lesson6.HelloChannels

com.sun.sgs.tutorial.server.lesson6.HelloChannelsSessionListener

org.jdesktop.wonderland.server.cell.ChannelComponentMO

org.jdesktop.wonderland.server.comms.WonderlandSessionListener$HandlerStore

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.