// Path: src/main/java/com/sulaco/fuse/akka/message/FuseInternalMessage.java
// public interface FuseInternalMessage extends FuseOriginChain {
//     
//     FuseMessageContext getContext();
// 
//     long getRequestId();
// 
//     long getTimestamp();
// 
//     FuseInternalMessage timestamp();
// }


import com.sulaco.fuse.akka.message.FuseInternalMessage;
package com.sulaco.fuse.akka.actor;



public class ChannelClosingActor extends FuseBaseActor {

    @Override
// Path: src/main/java/com/sulaco/fuse/akka/message/FuseInternalMessage.java
// public interface FuseInternalMessage extends FuseOriginChain {
//     
//     FuseMessageContext getContext();
// 
//     long getRequestId();
// 
//     long getTimestamp();
// 
//     FuseInternalMessage timestamp();
// }


// Path: src/main/java/com/sulaco/fuse/akka/actor/ChannelClosingActor.java
import com.sulaco.fuse.akka.message.FuseInternalMessage;

package com.sulaco.fuse.akka.actor;



public class ChannelClosingActor extends FuseBaseActor {

    @Override
    public void onMessage(FuseInternalMessage message) {