iocanel

<to uri="smtps://{{smtp.username}}@{{smtp.server}}?password={{smtp.password}}"/>

iocanel

public Map<node,result> execute(Command command) throws Exception {
    if (command == null) {
        throw new Exception("Command store not found");
    } else {
        //store the command to correlate it with the result.
        commandStore.getPending().put(command.getId(), command);
        //I create a timeout task and schedule it
        TimeoutTask timeoutTask = new TimeoutTask(command, commandStore);
        ScheduledFuture timeoutFuture = timeoutScheduler.schedule(timeoutTask, command.getTimeout(), TimeUnit.MILLISECONDS);
    }

iocanel

features:addurl mvn:net.cellar/assembly/1.0/xml/features
features:install spring-dm
features:install cellar
cluster:list

iocanel

<bean class="com.hazelcast.core.Hazelcast" destroy-method="shutdown" factory-method="newHazelcastInstance" id="hazelcast">
    <constructor-arg ref="config"/>
</bean>

<bean class="com.hazelcast.config.Config" id="config">
    <property name="groupConfig" ref="groupConfig"/>
</bean>

<bean class="com.hazelcast.config.GroupConfig" id="groupConfig">
    <property name="name">karaf</property>

iocanel

osgi:install -s mvn:com.hazelcast/hazelcast/1.9.3
osgi:install -s war:mvn:com.hazelcast/hazelcast-monitoring/1.9.3/war

iocanel

<reference id="instance" interface="com.hazelcast.core.HazelcastInstance">
    
<bean factory-method="getTopic" factory-ref="instance" id="echoTopic">
    <argument value="ECHO"/>
</bean>

iocanel

public class EchoListener implements MessageListener<string> {

    private ITopic topic;

    public void onMessage(String message) {
        System.out.println(message);
    }

    public ITopic getTopic() {
        return topic;

iocanel

<reference id="instance" interface="com.hazelcast.core.HazelcastInstance"/>
    
<bean factory-method="getTopic" factory-ref="instance" id="echoTopic">
    <argument value="ECHO"/>
</bean>
    
    
<bean class="net.iocanel.karaf.hazelcast.shell.EchoListener" id="listener">
    <property name="topic" ref="echoTopic"/>
</bean>

iocanel

@Command(scope = "hazelcast", name = "echo", description = "Echos a message to all cluster nodes")
public class EchoCommand extends HazelcastCommandSupport {
@Argument(index=0,name="message", description = "The message to echo", required = true, multiValued = false)
    private String message;

    private ITopic topic;

    @Override
    protected Object doExecute() throws Exception {
        if(topic != null) {

iocanel

CREATE TABLE users (
  username varchar(255) NOT NULL,
  password varchar(255) NOT NULL,
  PRIMARY KEY (username)
);
CREATE TABLE roles (
  username varchar(255) NOT NULL,
  role varchar(255) NOT NULL,
  PRIMARY KEY (username,role)
)