Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Override
- public SimpleChannel joinChannel(final String aNetwork, String aChannel)
- {
- final Semaphore _sema = new Semaphore(1);
- final SimpleChannel _simpleChan = new SimpleChannel();
- if (aNetwork.equals(_session.getBot().getServer().getHostname()))
- {
- _session.execute(new JoinChanCmd(aChannel), new JoinChanCallback(aChannel)
- {
- @Override
- public void gotSuccess(Channel aChanInfo)
- {
- _sema.release();
- }
- @Override
- public void gotFailure(String aErrorMsg)
- {
- _sema.release();
- }
- });
- }
- try
- {
- if (!_sema.tryAcquire(2, 10, TimeUnit.SECONDS))
- {
- // log couldn't acquire after 10 seconds
- }
- catch (InterruptedException aExc)
- {
- // log exc
- }
- return _simpleChan;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement