GVKun编程网logo

php – 放置FB.Event.subscribe的位置(functions.php位置)

9

想了解php–放置FB.Event.subscribe的位置的新动态吗?本文将为您提供详细的信息,我们还将为您解答关于functions.php位置的相关问题,此外,我们还将为您介绍关于AI中SubS

想了解php – 放置FB.Event.subscribe的位置的新动态吗?本文将为您提供详细的信息,我们还将为您解答关于functions.php位置的相关问题,此外,我们还将为您介绍关于AI中SubScribe插件怎么安装_subscribe插件安装教程、android – Subscriber类没有调用Event的公共方法、android – 构建proj时的EventBus异常 – Subscriber类没有名为onEvent的公共方法、com.google.common.eventbus.Subscribe的实例源码的新知识。

本文目录一览:

php – 放置FB.Event.subscribe的位置(functions.php位置)

php – 放置FB.Event.subscribe的位置(functions.php位置)

下面是我在我的网站上使用Facebook Like按钮(以及Share按钮)的代码.

它很棒.我点击了Like按钮,然后在我的Facebook帐户的个人资料页面上发布了一个很好的通知. Facebook甚至会自动生成一个恰好是我网站徽标的预览图像.精彩.我网站上的Like计数器总计正确.

所以我想在Like按钮上记录点击次数.根据this页面,代码为FB.Event.subscribe(‘edge.create’,function(response){});允许你这样做.

我在下面的代码中应该放置代码FB.Event.subscribe(‘edge.create’,function(response){});

    <html xmlns="http://www.w3.org/1999/xhtml" xmlns:fb="http://www.facebook.com/2008/fbml">

    <?PHP

    echo '<div id="fb-root"></div>';

    echo "<script type='text/javascript'>
      window.fbAsyncInit = function() {
        FB.init({appId: 'my_fb_app_id', status: true, cookie: true,
                 xfbml: true});
      };


      (function() {
        var e = document.createElement('script'); e.async = true;
        e.src = document.location.protocol +
          '//connect.facebook.net/en_US/all.js';
        document.getElementById('fb-root').appendChild(e);
      }());



    });

    </script>";


    echo '<script src="http://connect.facebook.net/en_US/all.js#xfbml=1"></script><fb:like href="" send="true" layout="button_count" width="450" show_faces="false" font="arial"></fb:like>'; 

?>

解决方法:

我不完全确定这是否正确,但根据this stack overflow thread,您将事件订阅代码放在FB.init()之后和匿名函数调用之前,

window.fbAsyncInit = function() {
    FB.init({
        appId  : 'sensored-app-id',
        status : true, // check login status
        cookie : true, // enable cookies to allow the server to access the session
        xfbml  : true  // parse XFBML
    });

    /* All the events registered */
    FB.Event.subscribe('comments.add', function (response) {
        // do something with response
        alert("comment added");
    });
};

(function() {
    var e = document.createElement('script');
    e.src = document.location.protocol + '//connect.facebook.net/fi_FI/all.js';
    e.async = true;
    document.getElementById('fb-root').appendChild(e);
}());

此外,如果您看到this developer’s code example,您会看到他也将事件订阅代码放在Facebook初始化代码之后.

AI中SubScribe插件怎么安装_subscribe插件安装教程

AI中SubScribe插件怎么安装_subscribe插件安装教程

AI中SubScribe插件怎么安装?subscribe软件主要用于增强路径绘图的性能,可以方便设计师快速绘制圆的相切线、快速拉直旋转对象以及将两条线段连接等效果,是一款AI路径绘图增强插件。那要怎么把subscribe插件安装到AI中呢?一起来看下具体的操作步骤吧。

AI中SubScribe插件怎么安装?

1、下载完成后点击subscribe安装程序,开始安装subscribe插件,进入subscribe安装界面,点击【Next】按钮,确认当前电脑未打开AI软件,点击【Next】按钮。

  2、接下来就是选择要安装的插件,只安装subscribe插件,选择subscribe插件就可以了,subscribe安装程序会自动检测到当前电脑上的所有AI版本,并且会自动选中其中的版本,当然也可以通过手动勾选相应的AI版本,等待subscribe插件安装完成。

  3、打开电脑上AI软件,弹出【About subscribe】界面,点击下面的【Activate】按钮,在弹出框【Activate subscribe】中输入激活码,然后点击【ok】按钮,弹出提示消息激活成功,点击【ok】按钮。

  4、重启软件后,在AI软件上面的菜单栏中,找到【帮助】--》【Astute Graphics】--》【SubScribe】,可以看到AI已经成功安装了subscribe插件,AI软件左侧的工具栏上多了几个工具,也就是subscribe插件的工具。

android – Subscriber类没有调用Event的公共方法

android – Subscriber类没有调用Event的公共方法

使用绿色Robot Eventbus时出错了
E/AndroidRuntime(2537): Caused by: de.greenrobot.event.EventBusException: Subscriber class com.example.MyActivity has no public methods called onEvent

细节:

我正在加载Activity,其中包含一个包含10个子片段的片段,而不是调用EventBus.getDefault().register(this);在每个嵌套(子)片段中,我在该片段的父活动中调用该寄存器.

解决方法

通过声明onEventMainThread方法和EventBus.getDefault().register(this)解决;在同一个片段中(应该在同一个类中声明)

android – 构建proj时的EventBus异常 – Subscriber类没有名为onEvent的公共方法

android – 构建proj时的EventBus异常 – Subscriber类没有名为onEvent的公共方法

所以,我的应用程序从/向我的MainActivity交换消息到/从后台服务,我使用 EventBus来处理它.我正在注册这两个组件

EventBus.getDefault().register(this);

在他们的onCreates.我正在发送/接收一个活动:

EventBus.getDefault().post(new MyMessagePojo("message"));

public void onEvent(MyMessagePojo event) { ... }

当我将项目从AndroidStudio运行到我的测试手机时,一切正常.但是,当我生成签名的APK时,我安装了应用程序并遇到以下异常崩溃:

Subscriber class my.package.MainActivity has no public methods called onEvent

它显然有的地方.我尝试在MainActivity中将它从onEvent更改为onEventMainThread,但没有成功.这是非常令人沮丧的,因为我即将发布应用程序,现在我无法解决这个问题.

我经历过this和this,但他们没有帮助.

有任何想法吗?

解决方法

这是在EventBus HOWTO文档中解决的.
https://github.com/greenrobot/EventBus/blob/master/HOWTO.md

使用以下代码仅保留onEvent函数.

-keepclassmembers class ** {
    public void onEvent*(**);
}

com.google.common.eventbus.Subscribe的实例源码

com.google.common.eventbus.Subscribe的实例源码

项目:fx-animation-editor    文件:SelectionResizeHandler.java   
@Subscribe
public void onSelectionResized(SelectionResizeEvent event) {
    if (timelineModel.getSelectedKeyFrame() == null) {
        return;
    }
    if (event.getType() == START) {
        startValues = new HashMap<>();
        filterByKeyAndForEach(getkeyvalues(),NodeModel::isSelected,this::storeStartkeyvalues);
    } else if (event.getType() == DRAG) {
        event.getNewPositions().keySet().forEach(node -> moveNode(node,event));
    } else if (event.getType() == FINISHED) {
        Map<keyvalueModel,Object> endValues = getEndValues(event);
        if (startValues != null && anyNodeMoved(endValues)) {
            commandStack.append(new NodeDragCommand(startValues,endValues,timelineModel,sceneModel));
        }
    }
}
项目:Biliomi    文件:HostWatchEventsService.java   
@Subscribe
public void onTwitchHostInEvent(TwitchHostInEvent event) {
  User channel = useRSService.getUser(event.getChannelName());
  boolean isCooldownExpired = isCooldownExpired(channel);

  if (isCooldownExpired) {
    hostRecordService.recordIncomingHost(channel,event.isAuto());

    if (settings.getReward() > 0) {
      pointsService.give(channel,settings.getReward());
    }

    Template template = templateDao.getByKey(HostWatchComponent.INCOMING_HOST_NOTICE_TEMPLATE);
    assert template != null; // Template cannot be null since it's set during install/update
    if (StringUtils.isNotEmpty(template.getTemplate())) {
      chat.say(Templater.template(template.getTemplate())
          .add("username",channel::getdisplayName)
          .add("points",pointsService.asstring(settings.getReward())));
    }
  }
}
项目:WebPLP    文件:PLPWebController.java   
@Subscribe
public void applicationThemeRequestCallback(ThemeRequestCallback event)
{
    if (event.requestedTheme().isPresent())
    {
        Theme applicationTheme = event.requestedTheme().get();
        try
        {
            stage.getScene().getStylesheets().clear();
            stage.getScene().getStylesheets().add(applicationTheme.getPath());
            return;
        }
        catch (MalformedURLException e)
        {
            console.warning("Unable to load application theme "
                    + applicationTheme.getName());
            return;
        }
    }

    console.warning("Unable to load application theme.");
}
项目:incubator-servicecomb-java-chassis    文件:TestMicroserviceWatchTask.java   
@Test
public void testWatchOpen(@Mocked ServiceRegistryConfig serviceRegistryConfig,@Mocked ServiceRegistryClient srClient,@Mocked Microservice microservice) {
  initWatch(serviceRegistryConfig,srClient,microservice);

  new MockUp<ServiceRegistryClient>(srClient) {
    @Mock
    void watch(String selfMicroserviceId,AsyncResultCallback<MicroserviceInstanceChangedEvent> callback,AsyncResultCallback<Void> onopen,AsyncResultCallback<Void> onClose) {
      onopen.success(null);
    }
  };

  Holder<Boolean> openHolder = new Holder<>();
  eventBus.register(new Object() {
    @Subscribe
    public void onopen(RecoveryEvent event) {
      openHolder.value = true;
    }
  });
  Assert.assertNull(openHolder.value);
  microserviceWatchTask.run();
  Assert.assertTrue(openHolder.value);
}
项目:incubator-servicecomb-java-chassis    文件:TestMicroserviceWatchTask.java   
@Test
public void testWatchFailed(@Mocked ServiceRegistryConfig serviceRegistryConfig,AsyncResultCallback<Void> onClose) {
      callback.fail(new Error("test Failed"));
    }
  };

  Holder<Throwable> holder = new Holder<>();
  eventBus.register(new Object() {
    @Subscribe
    public void onException(ExceptionEvent event) {
      holder.value = event.getThrowable();
    }
  });
  Assert.assertNull(holder.value);
  microserviceWatchTask.run();
  Assert.assertEquals("test Failed",holder.value.getMessage());
}
项目:WordnetLoom    文件:GraphController.java   
@Subscribe
public void onShowGraph(ShowGraphEvent event) {
    synset rootsynset = service.synsetRemote().findsynsetBySense(event.getSense(),Arrays.asList(1l,2l,3l));
    ui.releaseDataSetCache();

    if (rootsynset != null) {
        Map<Long,DataEntry> entries = service.synsetRemote()
                .prepareCacheForRootNode(rootsynset,3l),new NodeDirection[]{NodeDirection.LEFT,NodeDirection.TOP,NodeDirection.BottOM,NodeDirection.RIGHT});

        if (entries != null) {
            ui.setEntrySets((HashMap<Long,DataEntry>) entries);
        }
        //pobieranie synsetu z wcześniej pobranej mapy,aby otrzymać obiekt,który ma relacje (nie są leniwymi kolekcjami)
        DataEntry dataEntry = entries.get(rootsynset.getId());
        if (dataEntry != null) {
            rootsynset = dataEntry.getsynset();
        }
        ui.refreshView(rootsynset);
    } else {
        ui.clear();
    }
}
项目:wall-t    文件:Tileviewmodel.java   
@Subscribe
public final void updateTileviewmodel( final BuildTypeData data ) {
    if ( data != _buildTypeData )
        return;

    Platform.runLater( ( ) -> {
        _displayedname.set( Strings.isNullOrEmpty( data.getAliasName( ) ) ? data.getName( ) : data.getAliasName( ) );
        _running.setValue( data.hasRunningBuild( ) );
        _queued.setValue( data.isQueued( ) );

        updateLastFinishedDate( );
        updateTimeLeft( );
        updatePercentageComplete( );
        updateBackground( );
        updateIcon( );
    } );
}
项目:hygene    文件:NodeMetadataCache.java   
/**
 * Retrieves Metadata as soon as the layout is done.
 *
 * @param event a {@link LayoutDoneEvent}
 */
@Subscribe
public void layoutDone(final LayoutDoneEvent event) {
    if (currenTradius >= RADIUS_THRESHOLD) {
        retrievalExecutor.stop();
        return;
    }

    retrievalExecutor.run(() -> {
        retrieveMetadata(gfaFile,event.getSubgraph());
        if (Thread.interrupted()) {
            return;
        }
        pathCalculator.computePaths(event.getSubgraph());
        HygeneEventBus.getInstance().post(new NodeMetadataCacheUpdateEvent(event.getSubgraph()));
    });
}
项目:Charrizard    文件:CommandCaller.java   
@Subscribe
public void onTextMessage(MessageReceivedEvent event) {
    CGuild cGuild = charrizard.getCGuildManager().getGuild(event.getGuild());
    if (cGuild == null) {
        charrizard.getCGuildManager().createGuild(event.getGuild());
        cGuild = charrizard.getCGuildManager().getGuild(event.getGuild());
    }
    if (!event.getMessage().getContent().startsWith(prefix)) {
        CTextChannel cTextChannel = cGuild.getTextChannel(event.getTextChannel());
        if (cTextChannel == null) {
            cGuild.createTextChannel(event.getTextChannel());
            cTextChannel = cGuild.getTextChannel(event.getTextChannel());
        }
        cTextChannel.addMessage();
        return;
    }
    String[] args = event.getMessage().getContent().split(" ");
    args[0] = args[0].substring(1);
    Command command = commands.stream().filter(c -> c.getLabel().equals(args[0])).findFirst().orElse(null);
    if (command == null) {
        return;
    }
    cGuild.runcommand(command,new cmessage(event.getMessage()),args);
}
项目:googles-monorepo-demo    文件:OutsideEventBusTest.java   
public void testAnonymous() {
  final atomicreference<String> holder = new atomicreference<String>();
  final AtomicInteger deliveries = new AtomicInteger();
  EventBus bus = new EventBus();
  bus.register(new Object() {
    @Subscribe
    public void accept(String str) {
      holder.set(str);
      deliveries.incrementAndGet();
    }
  });

  String EVENT = "Hello!";
  bus.post(EVENT);

  assertEquals("Only one event should be delivered.",1,deliveries.get());
  assertEquals("Correct string should be delivered.",EVENT,holder.get());
}
项目:Biliomi    文件:DonationsEventService.java   
@Subscribe
public void onStreamLabsDonationEvent(StreamLabsDonationEvent event) {
  User user = useRSService.getUser(event.getUsername());
  if (user != null) {
    double reward = (event.getAmount() * DonationRegisterConstants.POINTS_MULTIPLIER);
    donationsService.registerDonation(user,event.getFormattedamount(),event.getMessage());
    pointsService.give(user,reward);

    Template template = templateDao.getByKey(DonationRegisterConstants.INCOMING_DONATION_NOTICE);
    assert template != null; // Template cannot be null since it's set during install/update
    if (StringUtils.isNotEmpty(template.getTemplate())) {
      chat.say(Templater.template(template.getTemplate())
          .add("username",user::getdisplayName)
          .add("points",pointsService.asstring(reward))
          .add("formattedamount",event::getFormattedamount)
          .add("message",event::getMessage));
    }
  }
}
项目:WebPLP    文件:PLPWebController.java   
@SuppressWarnings("restriction")
@Subscribe
public void registerWatchResult(RegWatchResponseEvent e) {
    if (!e.isSuccess())
        throw new IllegalArgumentException("There isn't a register with the name "
                + e.getRegisterName());

    String id = e.getRegisterID();
    String registerName = e.getRegisterName();
    LongProperty register = e.getRegObject();
    System.out.println("suc" + id + " -- " +  registerName + " -- " + register);
    register.addListener(new changelistener<Number>() {

        @Override
        public void changed(ObservableValue<? extends Number> observable,Number oldValue,Number newValue) {
            //watchedRegisters.refresh();
            System.out.println("Success" + id + " -- " +  registerName + " -- " + register);
            session.setAttribute("idd",register.getValue());
            //System.out.println("id is:   " + session.getAttribute("idd"));
        }

    });

}
项目:Biliomi    文件:CliCommandRouter.java   
@Subscribe
public void onConsoleInputEvent(ConsoleInputEvent event) {
  char identifier = event.getIdentifier();

  switch (identifier) {
    case PREFIX_COMMAND:
      runcommand(event);
      break;
    case PREFIX_CMD_COMMAND:
      executeConsoleCommand(event);
      break;
    case PREFIX_WHISPER:
      doWhisper(event);
      break;
    case PREFIX_SAY:
      doSay(event);
      break;
    default:
      break;
  }
}
项目:Cypher    文件:RootPresenter.java   
@Subscribe
private void toggleSettingsPane(ToggleEvent e){
    Platform.runLater(()-> {
        if (e == ToggleEvent.SHOW_SETTINGS && !showSettings){
            settingsPane.toFront();
            showSettings = true;
        }else if (e == ToggleEvent.HIDE_SETTINGS && showSettings){
            settingsPane.toBack();
            showSettings = false;
        }else if (e == ToggleEvent.TOGGLE_SETTINGS){
            if (showSettings){
                settingsPane.toBack();
            }else{
                settingsPane.toFront();
            }
            showSettings = !showSettings;
        }
    });
}
项目:Cypher    文件:RoomPresenter.java   
@Subscribe
private void toggleRoomSettings(ToggleEvent e) {
    if (e == ToggleEvent.SHOW_ROOM_SETTINGS && !showRoomSettings) {
        settingsPane.toFront();
        showRoomSettings = true;
    } else if (e == ToggleEvent.HIDE_ROOM_SETTINGS && showRoomSettings) {
        settingsPane.toBack();
        showRoomSettings = false;
    } else if (e == ToggleEvent.TOGGLE_ROOM_SETTINGS) {
        if (showRoomSettings) {
            settingsPane.toBack();
        } else {
            settingsPane.toFront();
        }
        showRoomSettings = !showRoomSettings;
    }
}
项目:Boilerplate    文件:MainActivity.java   
@Subscribe
public void onEventReceived(Event event) {
    if (event instanceof NetworkEvent) {
        handleNetworkEvent((NetworkEvent) event);

    } else if (event instanceof ApiEvent) {
        if (event.getSubscriber().equals(getClass().getSimpleName())) {
            handleApiEvents((ApiEvent) event);
        }
    }
}
项目:WebPLP    文件:PLPAddressBus.java   
@Subscribe
public void receivedWatchRequest(MemWatchRequestEvent e) {
    long address = e.getMemoryAddress();

    if (!validateAddress(address))
        return;

    LongProperty valueProperty = null;

    for(HashMap.Entry<String,IOMemoryModule> entry : modules.entrySet())
    {
        IOMemoryModule mod = entry.getValue();
        if(mod.isAddressWithModule(address))
        {
            if(!mod.isPhantom())
                valueProperty = mod.getMemoryValueProperty(address);
            else
            {
                //verify: why are we even calling read of the module if not interested in its value
                //mod.read(addr);
            }

            break;
        }


    }

    EventRegistry.getGlobalRegistry().post(new MemWatchResponseEvent(true,address,valueProperty));
}
项目:incubator-servicecomb-java-chassis    文件:MicroserviceRegisterTask.java   
@Subscribe
public void onMicroserviceInstanceHeartbeatTask(MicroserviceInstanceHeartbeatTask task) {
  if (task.getHeartbeatResult() != HeartbeatResult.SUCCESS && isSameMicroservice(task.getMicroservice())) {
    LOGGER.info("read MicroserviceInstanceHeartbeatTask status is {}",task.taskStatus);
    this.taskStatus = TaskStatus.READY;
    this.registered = false;
  }
}
项目:incubator-servicecomb-java-chassis    文件:ServiceCenterTask.java   
@Subscribe
public void onRegisterTask(AbstractRegisterTask task) {
  LOGGER.info("read {} status is {}",task.getClass().getSimpleName(),task.taskStatus);
  if (task.getTaskStatus() == TaskStatus.FINISHED) {
    registerInstanceSuccess = true;
  } else {
    onException();
  }
}
项目:WebPLP    文件:LEDdisplay.java   
@Subscribe
public void outputFromDevice(DeviceOutputEvent e) {
    if (e.getDeviceName() != this.deviceName)
        return;

    long value = (long)(e.getDeviceData());

    for(int i = 7; i >= 0; i--) {
        if((value & (long) Math.pow(2,i)) == (long) Math.pow(2,i))
            setLEDState(i,true);
        else
            setLEDState(i,false);
    }
}
项目:n4js    文件:TestEventQueue.java   
/**
 * Percepts any {@link TestEvent test event} and registers it to the underlying queue.
 *
 * @param event
 *            the percepted test event to register.
 */
@Subscribe
@AllowConcurrentEvents
public void receivedTestEvent(final TestEvent event) {
    synchronized (events) {
        events.put(event.getSessionId(),valueOf(event));
    }
    if (null != latch) {
        latch.countDown();
    }
}
项目:n4js    文件:SynchronousTesterFsmTest.java   
/**
 * Percepts a test session failure event,registers the session ID of the Failed session.
 *
 * @param event
 *            the failure event.
 */
@Subscribe
@AllowConcurrentEvents
public void sessionFailed(final SessionFailedEvent event) {
    LOGGER.info("Received test session Failed event. "
            + (event.getComment().isPresent() ? event.getComment().get() : ""));
    FailedSessionIds.add(event.getSessionId());
    countDown();
}
项目:n4js    文件:TestResultsView.java   
/**
 * Whenever a new test event from 'mangelhaft' on the Javascript side is being received by the HTTP server,this
 * method will be invoked.
 * <p>
 * <b>This is the only method in this class that may be invoked from a non-UI thread.</b>
 */
@Subscribe
@AllowConcurrentEvents
public void onTestEvent(TestEvent ev) {
    display.getDefault().asyncExec(() -> {
        notifyTestEvent(ev);
    });
}
项目:flume-release-1.7.0    文件:TestPollingPropertiesFileConfigurationProvider.java   
@Test
public void testPolling() throws Exception {

  // let first event fire
  Thread.sleep(2000L);

  final List<MaterializedConfiguration> events = Lists.newArrayList();

  Object eventHandler = new Object() {
    @Subscribe
    public synchronized void handleConfigurationEvent(MaterializedConfiguration event) {
      events.add(event);
    }
  };
  eventBus.register(eventHandler);
  configFile.setLastModified(System.currentTimeMillis());

  // Now wait for second event to fire
  Thread.sleep(2000L);

  Assert.assertEquals(String.valueOf(events),events.size());

  MaterializedConfiguration materializedConfiguration = events.remove(0);

  Assert.assertEquals(1,materializedConfiguration.getSourceRunners().size());
  Assert.assertEquals(1,materializedConfiguration.getSinkRunners().size());
  Assert.assertEquals(1,materializedConfiguration.getChannels().size());


}
项目:CustomWorldGen    文件:LoadController.java   
@Subscribe
public void propogateStateMessage(FMLEvent stateEvent)
{
    if (stateEvent instanceof FMLPreInitializationEvent)
    {
        modobjectList = buildModobjectList();
    }
    ProgressBar bar = ProgressManager.push(stateEvent.description(),activeModList.size(),true);
    for (ModContainer mc : activeModList)
    {
        bar.step(mc.getName());
        sendEventToModContainer(stateEvent,mc);
    }
    ProgressManager.pop(bar);
}
项目:ProjectAres    文件:EventUtils.java   
/**
 * Derived from {@link com.google.common.eventbus.AnnotatedSubscriberFinder#getAnnotatedMethodsInternal}
 */
public static boolean hasSubscriberMethods(Class<?> type) {
    for(Class<?> cls : Typetoken.of(type).getTypes().rawTypes()) {
        for(Method method : cls.getmethods()) {
            if(method.isAnnotationPresent(Subscribe.class)) return true;
        }
    }
    return false;
}
项目:ProjectAres    文件:PlayerOrderCache.java   
@Subscribe
public void onReconfigure(LocalServerReconfigureEvent event) {
    // Invalidate everything if local realms change
    if(event.getoldConfig() != null && !event.getoldConfig().realms().equals(event.getNewConfig().realms())) {
        prioritiesByPlayer.invalidateall();
    }
}
项目:event-sourcing-cqrs-examples    文件:TransactionsListener.java   
@Subscribe
@SuppressWarnings("unused")
public void handle(AccountWithdrawnEvent event) {
    TransactionProjection tx = new TransactionProjection(
            event.getAggregateId(),WITHDRAWAL,event.getAmount(),event.getTimestamp(),event.getVersion());
    transactionsRepository.save(tx);
}
项目:Biliomi    文件:PMResponseComponent.java   
@Subscribe
public void onIrcPrivateMessageEvent(IrcPrivateMessageEvent event) {
  if (event.getUsername().equalsIgnoreCase(IrcSession.SYstem_USER)) {
    return;
  }

  Template template = templateDao.getByKey(PM_RESPONSE_TEMPLATE_ID);
  if (template == null || StringUtils.isEmpty(template.getTemplate())) {
    return;
  }
  chat.whisper(event.getUsername(),Templater.template(template.getTemplate())
      .add("moderators",this::createModeratorList));
}
项目:Cypher    文件:RootPresenter.java   
@Subscribe
private void toggleLoadingScreen(ToggleEvent e) {
    Platform.runLater(() -> {
        if (e == ToggleEvent.SHOW_LOADING) {
            loadingPane.toFront();
        } else if (e == ToggleEvent.HIDE_LOADING) {
            loadingPane.toBack();
        }
    });
}
项目:Cypher    文件:RoomPresenter.java   
@Subscribe
private void handleLoginStateChange(ToggleEvent e) {
    if (e == ToggleEvent.logoUT) {
        showRoomSettings = false;
        settingsPane.toBack();
    }
}
项目:Cypher    文件:RoomCollectionPresenter.java   
@Subscribe
private void roomCollectionChanged(RoomCollection roomCollection) {
    Platform.runLater(()->{
        if (backendListForView != null) {
            backendListForView.dispose();
        }
        backendListForView = new FXThreadedobservableListWrapper<>(roomCollection.getRoomsproperty());

        roomListView.setCellFactory(listView -> {
            RoomListItemView roomListItemView = new RoomListItemView();
            roomListItemView.getView();
            return (RoomListItemPresenter) roomListItemView.getPresenter();
        });

        roomListView.setItems(backendListForView.getList());

        serverName.textproperty().unbind();
        if (roomCollection instanceof Server) {
            serverName.textproperty().bind(
                new FXThreadedobservableValueWrapper<>(
                    ((Server) roomCollection).nameproperty()
                )
            );
        } else if (roomCollection instanceof PMCollection) {
            serverName.textproperty().setValue(bundle.getString("pm"));
        } else if (roomCollection instanceof GeneralCollection) {
            serverName.textproperty().setValue(bundle.getString("general"));
        }

        // Handle room selection (selects the first room in the RoomCollection if the RoomCollection
        // isn't empty and if the prevIoUsly selected room isn't in the current RoomCollection)
        if (roomCollection.getRoomsproperty().contains(client.getSelectedRoom())) {
            roomListView.getSelectionModel().select(client.getSelectedRoom());
        } else if (roomCollection.getRoomsproperty().size() > 0) {
            eventBus.post(roomCollection.getRoomsproperty().get(0));
            roomListView.getSelectionModel().select(0);
        }
    });
}
项目:Cypher    文件:RoomCollectionPresenter.java   
@Subscribe
private void handleLoginStateChange(ToggleEvent e) {
    if (e == ToggleEvent.logoUT) {
        showDirectory = false;
        directoryPane.toBack();
    }
}
项目:Cypher    文件:LoadingPresenter.java   
@Subscribe
private void toggleLoadingScreen(ToggleEvent e) {
    Platform.runLater(() -> {
        if (e == ToggleEvent.SHOW_LOADING) {
            imageView.setimage(new Image(LoadingPresenter.class.getResourceAsstream("/images/loading.gif")));
        } else if (e == ToggleEvent.HIDE_LOADING) {
            imageView.setimage(null);
        }
    });
}
项目:wall-t    文件:Wallviewmodel.java   
@Subscribe
public void updateBuildList( final IBuildTypeManager buildManager ) {
    Platform.runLater( ( ) -> {
        _displayedBuilds.forEach( _eventBus::unregister );
        _displayedBuilds.setAll( (List<Tileviewmodel>) buildManager.getMonitoredBuildTypes( ).stream( )
                .map( _tileviewmodeFactory::forBuildTypeData )
                .collect( Collectors.toList( ) ) );
        _displayedBuilds.forEach( _eventBus::register );
    } );
}
项目:ProjectAres    文件:RestartManager.java   
@Subscribe
public void onReconfigure(LocalServerReconfigureEvent event) {
    final Instant oldTime,newTime;
    final String oldReason,newReason;
    final int oldPriority,newPriority;

    if(event.getoldConfig() == null) {
        oldTime = null;
        oldReason = null;
        oldPriority = ServerDoc.Restart.Priority.norMAL;
    } else {
        oldTime = event.getoldConfig().restart_queued_at();
        oldReason = event.getoldConfig().restart_reason();
        oldPriority = event.getoldConfig().restart_priority();
    }

    newTime = event.getNewConfig().restart_queued_at();
    newReason = event.getNewConfig().restart_reason();
    newPriority = event.getNewConfig().restart_priority();

    if(Objects.equals(oldTime,newTime) &&
       Objects.equals(oldReason,newReason) &&
       Objects.equals(oldPriority,newPriority)) return;

    if(oldTime != null) {
        logger.info("Restart cancelled");
        currentRequest = null;
        eventBus.post(new CancelRestartEvent());
    }

    if(newTime != null) {
        logger.info("Restart requested at " + newTime +
                    ",with " + newPriority +
                    " priority,because \"" + newReason + '"');
        currentRequest = new RequestRestartEvent(logger,newReason,newPriority,this::restartIfRequested);
        eventBus.post(currentRequest);
        restartIfRequested();
    }
}
项目:Biliomi    文件:ChatService.java   
@Subscribe
public void onIrcusermodeEvent(IrcusermodeEvent event) {
  if (event.isModeratorMode()) {
    User user = useRSService.getUser(event.getUsername());
    if (!user.isModerator()) {
      user.setModerator(true);
      userDao.save(user);
    }
  }
}
项目:bloomfilter-center    文件:ScheduleBloomFilterLoadTrigger.java   
/**
 * onLoadCommand
 *
 * @param command
 */
@Subscribe
public void onLoadCommand(BloomFilterCommand command) {
    if (command != null && command.getAction() == BloomFilterCommand.BloomFilteraction.FORCELOAD) {
        String cmd = command.getCommand();
        if (cmd != null && cmd.equalsIgnoreCase(getBloomFilterName())) {
            triggerLoad(true);
            if (logger.isInfoEnabled()) {
                logger.info("ScheduleBloomFilterLoadTrigger,onLoadCommand,BloomFilterCommand[" + command + "]");
            }
        }
    }
}
项目:Biliomi    文件:ComponentManager.java   
@Subscribe
public void onIrcConnectedEvent(IrcChannelJoinedEvent event) {
  logger.info("Initializing components...");

  coreComponents.forEach(Component::init);
  components.forEach(Component::init);

  logger.info("All components loaded succesfully");
  logger.info("Biliomi is ready for commands!");
}
项目:CustomWorldGen    文件:FMLContainer.java   
@Subscribe
public void modPreinitialization(FMLPreInitializationEvent evt)
{
    // Initialize all Forge/Vanilla registries {invoke the static init)
    if (ForgeRegistries.ITEMS == null)
        throw new RuntimeException("Something horrible went wrong in init,ForgeRegistres didn't create...");
}

今天的关于php – 放置FB.Event.subscribe的位置functions.php位置的分享已经结束,谢谢您的关注,如果想了解更多关于AI中SubScribe插件怎么安装_subscribe插件安装教程、android – Subscriber类没有调用Event的公共方法、android – 构建proj时的EventBus异常 – Subscriber类没有名为onEvent的公共方法、com.google.common.eventbus.Subscribe的实例源码的相关知识,请在本站进行查询。

本文标签: