/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson5;
import java.io.Serializable;
import java.nio.ByteBuffer;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.ManagedReference;
/**
* Simple example {@link ClientSessionListener} for the Project Darkstar
* Server.
* <p>
* Logs each time a session receives data or logs out, and echoes
* any data received back to the sender.
*/
class HelloEchoSessionListener
implements Serializable, ClientSessionListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloEchoSessionListener.class.getName());
/** The session this {@code ClientSessionListener} is listening to. */
private final ManagedReference<ClientSession> sessionRef;
/** The name of the {@code ClientSession} for this listener. */
private final String sessionName;
/**
* Creates a new {@code HelloEchoSessionListener} for the given session.
*
* @param session the session this listener is associated with
*/
public HelloEchoSessionListener(ClientSession session) {
if (session == null) {
throw new NullPointerException("null session");
}
sessionRef = AppContext.getDataManager().createReference(session);
sessionName = session.getName();
}
/**
* Returns the session for this listener.
*
* @return the session for this listener
*/
protected ClientSession getSession() {
// We created the ref with a non-null session, so no need to check it.
return sessionRef.get();
}
/**
* {@inheritDoc}
* <p>
* Logs when data arrives from the client, and echoes the message back.
*/
public void receivedMessage(ByteBuffer message) {
ClientSession session = getSession();
logger.log(Level.INFO, "Message from {0}", sessionName);
// Echo message back to sender
session.send(message);
}
/**
* {@inheritDoc}
* <p>
* Logs when the client disconnects.
*/
public void disconnected(boolean graceful) {
String grace = graceful ? "graceful" : "forced";
logger.log(Level.INFO,
"User {0} has logged out {1}",
new Object[] { sessionName, grace }
);
}
}