public class TextBasedIoHandlerAdapter extends IoHandlerAdapter {

	private static final Logger LOG = LoggerFactory.getLogger(TextBasedIoHandlerAdapter.class);

	private final KieContainerCommandService batchCommandService;

	public TextBasedIoHandlerAdapter(KieContainerCommandService batchCommandService) {
		this.batchCommandService = batchCommandService;
	}

	@Override
	public void messageReceived(IoSession session, Object message) throws Exception {
		String completeMessage = message.toString();
		LOG.debug("Received message '{}'", completeMessage);
		if (completeMessage.trim().equalsIgnoreCase("exit")) {
			session.closeOnFlush();
			return;
		}

		String[] elements = completeMessage.split("\\|");
		LOG.debug("Container id {}", elements[0]);
		ServiceResponse<String> result = batchCommandService.callContainer(elements[0], elements[1],
				MarshallingFormat.JSON, null);

		if (result.getType().equals(ServiceResponse.ResponseType.SUCCESS)) {
			session.write(result.getResult());
			LOG.debug("Successful message written with content '{}'", result.getResult());
		} else {
			session.write(result.getMsg());
			LOG.debug("Failure message written with content '{}'", result.getMsg());
		}
	}
}

public class MinaDroolsKieServerExtension implements KieServerExtension {

	public static final String DROOLS_EXTENSION = DroolsKieServerExtension.EXTENSION_NAME;
	public static final String EXTENSION_NAME = "Drools-Mina";
	public static final String MINA_CAPABILITY = "BRM-Mina";

	private static final Logger LOG = LoggerFactory.getLogger(MinaDroolsKieServerExtension.class);

	private static final String MINA_HOST = System.getProperty("org.kie.server.drools-mina.ext.port", "localhost");
	private static final String MINA_PORT = System.getProperty("org.kie.server.drools-mina.ext.port", "9123");

	private IoAcceptor acceptor;
	private boolean initialized = false;

	@Override
	public boolean isActive() {
		return true;
	}

	@Override
	public void init(KieServerImpl kieServer, KieServerRegistry registry) {

		KieServerExtension droolsExtension = registry.getServerExtension(DROOLS_EXTENSION);
		if (droolsExtension == null) {
			LOG.warn("No Drools extension available, quiting...");
			return;
		}

		KieContainerCommandService batchCommandService = findByType(droolsExtension.getServices(),
				KieContainerCommandService.class);

		if (batchCommandService != null) {
			acceptor = new NioSocketAcceptor();
			acceptor.getFilterChain().addLast("codec",
					new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));

			acceptor.setHandler(new TextBasedIoHandlerAdapter(batchCommandService));
			acceptor.getSessionConfig().setReadBufferSize(2048);
			acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
			try {
				acceptor.bind(new InetSocketAddress(MINA_HOST, Integer.parseInt(MINA_PORT)));

				LOG.info("{} -- Mina server started at {} and port {}", toString(), MINA_HOST, MINA_PORT);
			} catch (IOException e) {
				LOG.error("Unable to start Mina acceptor due to {}", e.getMessage(), e);
			}

			initialized = true;
		}
	}

	@Override
	public void destroy(KieServerImpl kieServer, KieServerRegistry registry) {
		if (acceptor != null) {
			acceptor.dispose();
			acceptor = null;
		}

		LOG.info("{} -- Mina server stopped", toString());
	}

	@Override
	public List<Object> getAppComponents(SupportedTransports type) {
		// Nothing for supported transports (REST or JMS)
		return Collections.emptyList();
	}

	@Override
	public <T> T getAppComponents(Class<T> serviceType) {

		return null;
	}

	@Override
	public String getImplementedCapability() {
		return MINA_CAPABILITY;
	}

	@Override
	public List<Object> getServices() {
		return Collections.emptyList();
	}

	@Override
	public String getExtensionName() {
		return EXTENSION_NAME;
	}

	@Override
	public Integer getStartOrder() {
		return 20;
	}

	@Override
	public String toString() {
		return EXTENSION_NAME + " KIE Server extension";
	}

	@Override
	public boolean isInitialized() {
		return initialized;
	}

	@Override
	public void createContainer(String id, KieContainerInstance kieContainerInstance, Map<String, Object> parameters) {
		// Empty, already handled by the `Drools` extension
	}

	@Override
	public void updateContainer(String id, KieContainerInstance kieContainerInstance, Map<String, Object> parameters) {
		// Empty, already handled by the `Drools` extension
	}

	@Override
	public boolean isUpdateContainerAllowed(String id, KieContainerInstance kieContainerInstance,
			Map<String, Object> parameters) {
		// Empty, already handled by the `Drools` extension
		return false;
	}

	@Override
	public void disposeContainer(String id, KieContainerInstance kieContainerInstance, Map<String, Object> parameters) {
		// Empty, already handled by the `Drools` extension
	}

	@SuppressWarnings("unchecked")
	private <T> T findByType(List<Object> services, Class<T> clazz) {
		return services.stream().filter(svc -> clazz.isAssignableFrom(svc.getClass())).map(svc -> (T) svc).findFirst()
				.get();
	}
}

package org.jbpm.test;

public class Person  implements java.io.Serializable {
    
    private Integer age;
    private String name;

    // constructors, getters and setters
}