import io.nats.client.MessageHandler; //导入依赖的package包/类
protected MessageHandler getMessageHandler() {
	return new MessageHandler() {
		@Override
		public void onMessage(Message m) {
			R s = decodeData(m);
			if (logger.isTraceEnabled()) {
				logger.trace("Received by {} on Subject '{}' sharing Queue '{}': {}.", StandardNatsToSparkConnectorImpl.this, m.getSubject(), queue, s);
			}
			store(s);
		}
	};
}
 

import io.nats.client.MessageHandler; //导入依赖的package包/类
protected MessageHandler getMessageHandler() {
	return new MessageHandler() {
		@Override
		public void onMessage(Message m) {
			final Tuple2<String, V> s = decodeTuple(m);
			
			if (logger.isTraceEnabled()) {
				logger.trace("Received by {} on Subject '{}': {}.", StandardNatsToKeyValueSparkConnectorImpl.this, m.getSubject(), s);
			}
									
			store(s);
		}
	};
}
 

import io.nats.client.MessageHandler; //导入依赖的package包/类
private SubscriptionImpl createSubscription(String subject, String qgroup,
                                            io.nats.streaming.MessageHandler cb,
                                            StreamingConnectionImpl conn,
                                            SubscriptionOptions opts) {
    return new SubscriptionImpl(subject, qgroup, cb, conn, opts);
}
 

import io.nats.client.MessageHandler; //导入依赖的package包/类
@Override
public Subscription subscribe(String subject, io.nats.streaming.MessageHandler cb)
        throws IOException, InterruptedException {
    return subscribe(subject, cb, null);
}
 

import io.nats.client.MessageHandler; //导入依赖的package包/类
abstract protected MessageHandler getMessageHandler();