Java IRCUser类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.schwering.irc.lib.IRCUser类的典型用法代码示例。如果您正苦于以下问题：Java IRCUser类的具体用法？Java IRCUser怎么用？Java IRCUser使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

IRCUser类属于org.schwering.irc.lib包，在下文中一共展示了IRCUser类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: onKick

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onKick(String channel, IRCUser user, String passiveNick, String msg) {

    // check to see if I got kick and if so rejoin if autoRejoin is on
    if (passiveNick.equals(connection.getNick()) && configuration.isAutoRejoin()) {
        endpoint.joinChannel(channel);
    }

    if (configuration.isOnKick()) {
        Exchange exchange = endpoint.createOnKickExchange(channel, user, passiveNick, msg);
        try {
            getProcessor().process(exchange);
        } catch (Exception e) {
            handleException(e);
        }
    }
}

开发者ID:HydAu，项目名称:Camel，代码行数:18，代码来源:IrcConsumer.java

示例2: onPrivmsg

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onPrivmsg(String arg0, IRCUser arg1, String arg2) {
	final String message;

	if (arg2.startsWith("ACTION")) {
		message = "* " + arg1.getNick() + " " + arg2.substring(6);
	} else {
		message = "&lt;<font color='#003366'>" + arg1.getNick()
				+ "</font>&gt; " + arg2;
	}

	runOnUiThread(new Runnable() {
		@Override
		public void run() {
			chatBox.append(Html.fromHtml(message + "<br />"));
			scrollDown();
		}
	});
}

开发者ID:cherrymathew，项目名称:evend，代码行数:20，代码来源:ChatActivity.java

示例3: IRCMessage

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
public IRCMessage(String channel, IRCUser user, String message) {
    super(SCHEMA);
    this.put("timestamp", System.currentTimeMillis());
    this.put("channel", channel);
    this.put("message", message);
    this.put("user", new Struct(SCHEMA.field("user").schema())
            .put("nick", user.getNick())
            .put("username", user.getUsername())
            .put("host", user.getHost())
    );
}

开发者ID:amient，项目名称:hello-kafka-streams，代码行数:12，代码来源:IRCMessage.java

示例4: onPrivmsg

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onPrivmsg(String channel, IRCUser u, String msg) {
    IRCMessage event = new IRCMessage(channel, u, msg);
    //FIXME kafka round robin default partitioner seems to always publish to partition 0 only (?)
    long ts = event.getInt64("timestamp");
    Map<String, ?> srcOffset = Collections.singletonMap(TIMESTAMP_FIELD, ts);
    Map<String, ?> srcPartition = Collections.singletonMap(CHANNEL_FIELD, channel);
    SourceRecord record = new SourceRecord(srcPartition, srcOffset, topic, KEY_SCHEMA, ts, IRCMessage.SCHEMA, event);
    queue.offer(record);
}

开发者ID:amient，项目名称:hello-kafka-streams，代码行数:11，代码来源:IRCFeedTask.java

示例5: onInvite

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onInvite(String chan, IRCUser user, String passiveNick) {
  String content = user.getNick() + " invited me to join " + chan;
  logger.info(content);
  joinChannel(chan);
  this.repository.add(chan);
  this.bus.broadcast(message(content)).as("irc.invited");
}

开发者ID:devnull-tools，项目名称:boteco，代码行数:9，代码来源:BotecoIrcEventListener.java

示例6: onKick

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onKick(String chan, IRCUser user, String passiveNick, String msg) {
  if (passiveNick.equals(configuration.getNickname())) {
    String content = user.getNick() + " kicked me from " + chan;
    logger.info(content);
    this.bus.broadcast(message(content)).as("irc.kicked");
    this.repository.remove(chan);
  }
}

开发者ID:devnull-tools，项目名称:boteco，代码行数:10，代码来源:BotecoIrcEventListener.java

示例7: onPrivmsg

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onPrivmsg(String target, IRCUser user, String msg) {
	LOG.debug("[{}] {}: {}.", target, user.getNick(), msg);

	WikipediaEditEvent event = WikipediaEditEvent.fromRawEvent(
			System.currentTimeMillis(),
			target,
			msg);

	if (event != null) {
		if (!edits.offer(event)) {
			LOG.debug("Dropping message, because of full queue.");
		}
	}
}

开发者ID:axbaretto，项目名称:flink，代码行数:16，代码来源:WikipediaEditEventIrcStream.java

示例8: onKick

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
@Override
public void onKick(String channel, IRCUser user, String passiveNick, String msg) {

    // check to see if I got kick and if so rejoin if autoRejoin is on
    if (passiveNick.equals(connection.getNick()) && endpoint.getConfiguration().isAutoRejoin()) {
        endpoint.joinChannel(channel);
    }
}

开发者ID:HydAu，项目名称:Camel，代码行数:9，代码来源:IrcProducer.java

示例9: IrcMessage

import org.schwering.irc.lib.IRCUser; //导入依赖的package包/类
public IrcMessage(String messageType, String target, IRCUser user, String message) {
    this.messageType = messageType;
    this.target = target;
    this.user = user;
    this.message = message;
    setBody(message);
}

开发者ID:HydAu，项目名称:Camel，代码行数:8，代码来源:IrcMessage.java