Wowza Streaming Engineのカスタマイズ モジュール作成編

package net.densanlabs;

import com.wowza.wms.application.*;
import com.wowza.wms.amf.*;
import com.wowza.wms.client.*;
import com.wowza.wms.module.*;
import com.wowza.wms.request.*;
import com.wowza.wms.stream.*;
import com.wowza.wms.rtp.model.*;
import com.wowza.wms.httpstreamer.model.*;
import com.wowza.wms.httpstreamer.cupertinostreaming.httpstreamer.*;
import com.wowza.wms.httpstreamer.smoothstreaming.httpstreamer.*;

public class HelloWowzaCustomize extends ModuleBase {

    public void onAppStart(IApplicationInstance appInstance) {
        String fullname = appInstance.getApplication().getName() + "/" + appInstance.getName();
        getLogger().info("アプリが起動しました: " + fullname);
    }

    public void onAppStop(IApplicationInstance appInstance) {
        String fullname = appInstance.getApplication().getName() + "/" + appInstance.getName();
        getLogger().info("アプリが停止しました: " + fullname);
    }

    // 新しい配信接続があった場合に呼ばれる
    public void onConnect(IClient client, RequestFunction function, AMFDataList params) {
        getLogger().info("新しいClientから接続がありました: " + client.getClientId());
    }

    // 配信接続を受け付けた場合に呼ばれる
    public void onConnectAccept(IClient client) {
        getLogger().info("Clientからの接続を受け付けました: " + client.getClientId());
    }

    public void onConnectReject(IClient client) {
        getLogger().info("Clientからの接続を拒否しました: " + client.getClientId());
    }

    // 配信切断された場合に呼ばれる
    public void onDisconnect(IClient client) {
        getLogger().info("Clientが切断しました: " + client.getClientId());
    }

}