项目：phonk
文件：PDevice.java
/**
* Gets notifications from other apps.
* In order to work to must enable the access of notifications in your device settings
*
* @param callback
* @status TOREVIEW
*/
@ProtoMethod
public void onNewNotification(final ReturnInterface callback) {
if (!isNotificationServiceRunning()) {
showNotificationsManager();
}
onNotification = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
ReturnObject ret = new ReturnObject();
ret.put("package",intent.getStringExtra("package"));
ret.put("title",intent.getStringExtra("title"));
ret.put("text",intent.getStringExtra("text"));
callback.event(ret);
}
};
LocalbroadcastManager.getInstance(getContext()).registerReceiver(onNotification,new IntentFilter("Msg"));
}
/**
* unregisterReceiver
*
* @param loaded mloaded
*/
public static void unregisterReceiver(ApkLoaded loaded) {
String key = loaded.getApkPath();
if (!CONTEXT_MAP.containsKey(key)) {
return;
}
Context context = CONTEXT_MAP.get(key);
if (broADCAST_RECEIVER_MAP.containsKey(key)) {
LinkedList<broadcastReceiver> receivers = broADCAST_RECEIVER_MAP.get(key);
for (int i = 0; i < receivers.size(); i++) {
context.unregisterReceiver(receivers.get(i));
}
broADCAST_RECEIVER_MAP.remove(key);
}
CONTEXT_MAP.containsKey(key);
}
项目：BackTube
文件：PlayerService.java
@CheckResult
private broadcastReceiver newbroadcastReceiver() {
return new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
switch (intent.getAction()) {
case ServiceAction.HIDE:
resetViewParams(mHideParams);
break;
case ServiceAction.SHOW:
resetViewParams(mParams);
break;
case ServiceAction.STOP:
stopSelf();
break;
case ServiceAction.START:
default:
throw new IllegalStateException();
}
}
};
}
项目：LeCatApp
文件：LoginActivity.java
private void registMyRecivier()
{
filter = new IntentFilter(Constant.REENTER);
mReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
String action = intent.getAction();
if(action.equals(Constant.REENTER))
{
LogUtil.d("dfy","收到重新登录的请求");
isNeedJump = false;
// LogUtil.d("dfy","loginBiz = "+loginBiz);
loginBiz = null;
loginBiz = new LoginBiz(loginInstance);
// LogUtil.d("dfy","loginBiz = "+loginBiz);
login();
}
}
};
}
public Registeractivity() {
if (HotFix.PREVENT_VERIFY) {
System.out.println(VerifyLoad.class);
}
this.recever = new broadcastReceiver(this) {
final /* synthetic */ Registeractivity this$0;
{
if (HotFix.PREVENT_VERIFY) {
System.out.println(VerifyLoad.class);
}
this.this$0 = this$0;
}
public void onReceive(Context arg0,Intent arg1) {
this.this$0.finish();
}
};
}
项目：react-native-caller-id-android
文件：InCall.java
@Override
protected void onResume() {
super.onResume();
IntentFilter filter = new IntentFilter();
filter.addAction("FINISH_ACTIVITY");
receiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if(isAboveLolipop) {
finishAndRemoveTask();
} else {
finish();
}
}
};
registerReceiver(receiver,filter);
}
项目：localcloud_fe
文件：NetworkManager.java
/**
* Sets the context of the Command. This can then be used to do things like
* get file paths associated with the Activity.
*
* @param cordova The context of the main Activity.
* @param webView The CordovaWebView Cordova is running in.
*/
public void initialize(CordovaInterface cordova,CordovaWebView webView) {
super.initialize(cordova,webView);
this.sockMan = (ConnectivityManager) cordova.getActivity().getSystemService(Context.CONNECTIVITY_SERVICE);
this.connectionCallbackContext = null;
// We need to listen to connectivity events to update navigator.connection
IntentFilter intentFilter = new IntentFilter();
intentFilter.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
if (this.receiver == null) {
this.receiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
// (The null check is for the ARM Emulator,please use Intel Emulator for better results)
if(NetworkManager.this.webView != null)
updateConnectionInfo(sockMan.getActiveNetworkInfo());
}
};
webView.getContext().registerReceiver(this.receiver,intentFilter);
}
}
/**
* broadcast receiver to check outgoing call
*/
private void initOutgoingbroadcastReceiver() {
OutgoingbroadcastReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if (intent.getAction().equals(Intent.ACTION_NEW_OUTGOING_CALL)) {
isInCall = true;
if (isInCall == true) {
smallMediaPlayer = SmallMediaPlayer.getInstance(context);
bigNotification = false;
pauseMedia();
}
}
}
};
IntentFilter filter = new IntentFilter(Intent.ACTION_NEW_OUTGOING_CALL);
context.registerReceiver(OutgoingbroadcastReceiver,filter);
}
private void callPvDataService() {
broadcastReceiver broadcastReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
LocalbroadcastManager.getInstance(context).unregisterReceiver(this);
if (intent.getBooleanExtra("success",true)) {
updateScreen();
} else {
Toast.makeText(context,intent.getStringExtra("message"),Toast.LENGTH_LONG).show();
}
}
};
IntentFilter intentFilter = new IntentFilter(PvDataService.class.getName());
LocalbroadcastManager.getInstance(getContext())
.registerReceiver(broadcastReceiver,intentFilter);
PvDataService.callLive(getContext(),picked.year,picked.month,picked.day);
}
项目：AndroidSensors
文件：WifiMeasurementsGatherer.java
private broadcastReceiver definebroadcastReceiverFor(final FlowableEmitter<SensorRecord> subscriber){
return new broadcastReceiver() {
Timer timer = new Timer();
long prevCallTime = new Date().getTime();
@Override
public void onReceive(Context context,Intent intent) {
long actualTime = new Date().getTime();
long delay = calculateDiffDelay(prevCallTime,actualTime);
prevCallTime = actualTime;
subscriber.onNext(new WifiMeasurementsRecord(wifiManager.getScanResults()));
if (delay > 0)
timer.schedule(createScanTask(),delay);
else
createScanTask().run();
}
};
}
@Nullable
@Override
public View onCreateView(LayoutInflater inflater,ViewGroup container,Bundle savedInstanceState) {
View mView = inflater.inflate(R.layout.seal_mine_fragment,container,false);
isDebug = getContext().getSharedPreferences("config",getContext().MODE_PRIVATE).getBoolean("isDebug",false);
initViews(mView);
initData();
//设置广播接收者 更新用户头像和昵称
broadcastManager.getInstance(getActivity()).addAction(SealConst.CHANGEINFO,new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
updateUserInfo();
}
});
compareversion();
return mView;
}
项目：TYT
文件：T_MyFund_AccountFinancingFragment.java
/**
* 注册广播接收者
*/
private void initbroadcastReceiver() {
mbroadcastManager = LocalbroadcastManager.getInstance(getActivity());
IntentFilter intentFilter = new IntentFilter();
intentFilter.addAction(AppDelegate.ACTION_T_FINANCING_ACCOUNT_SEARCH);
mReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
arguments = intent.getStringExtra(AppDelegate.ACTION_T_ACCOUNT_SEARCH);
// 更新数据
pageIndex = 1;
isFirstLoading = true;
onBackgrounds();
}
};
mbroadcastManager.registerReceiver(mReceiver,intentFilter);
}
项目：Android-2017
文件：TimerActivity.java
@Override
protected void onResume() {
super.onResume();
// registramos un broadcast receiver
tickReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if (intent.getAction().compareto(Intent.ACTION_TIME_TICK) == 0) {
tvHour.setText(getHour());
tvMinute.setText(getMinute());
}
}
};
registerReceiver(tickReceiver,new IntentFilter(Intent.ACTION_TIME_TICK));
if (!set.isRunning()) {
set.start();
}
}
private void addStateListener() {
if (this.stateReceiver == null) {
this.stateReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
onBluetoothStateChange(intent);
}
};
}
try {
IntentFilter intentFilter = new IntentFilter(BluetoothAdapter.ACTION_STATE_CHANGED);
webView.getContext().registerReceiver(this.stateReceiver,intentFilter);
} catch (Exception e) {
LOG.e(TAG,"Error registering state receiver: " + e.getMessage(),e);
}
}
项目：Phoenix-for-VK
文件：AccountsSettings.java
@Override
public Observable<Integer> observeChanges() {
return Observable.create(e -> {
broadcastReceiver receiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if (nonNull(intent) && WHAT_ACCOUNT_CHANGE.equals(intent.getAction())) {
e.onNext(intent.getExtras().getInt(Extra.ACCOUNT_ID));
}
}
};
e.setCancellable(() -> LocalbroadcastManager.getInstance(app).unregisterReceiver(receiver));
if (!e.isdisposed()) {
LocalbroadcastManager.getInstance(app).registerReceiver(receiver,new IntentFilter(WHAT_ACCOUNT_CHANGE));
}
});
}
项目：Sprog-App
文件：PoemsLoader.java
public static void loadPoems(final Context context,final MainPresenter presenter) {
File poems_file = new File(context.getExternalFilesDir(Environment.DIRECTORY_DOWNLOADS),"poems.json");
File poems_old_file = new File(context.getExternalFilesDir(Environment.DIRECTORY_DOWNLOADS),"poems_old.json");
if (poems_file.exists()) {
poems_file.renameto(poems_old_file);
}
String url = "https://almoturg.com/poems.json";
DownloadManager.Request request = new DownloadManager.Request(Uri.parse(url));
request.setDescription("Sprog poems");
request.setTitle("Sprog");
request.setNotificationVisibility(DownloadManager.Request.VISIBILITY_VISIBLE);
request.setDestinationInExternalFilesDir(context,Environment.DIRECTORY_DOWNLOADS,"poems.json");
// get download service and enqueue file
DownloadManager manager = (DownloadManager) context.getSystemService(Context.DOWNLOAD_SERVICE);
receiver = new broadcastReceiver() {
public void onReceive(Context ctxt,Intent intent) {
if (intent.getLongExtra(DownloadManager.EXTRA_DOWNLOAD_ID,-1) != downloadID){return;}
context.unregisterReceiver(PoemsLoader.receiver);
PoemsLoader.receiver = null;
presenter.downloadComplete();
}
};
context.registerReceiver(receiver,new IntentFilter(DownloadManager.ACTION_DOWNLOAD_COMPLETE));
downloadID = manager.enqueue(request);
}
/**
* Sets the context of the Command. This can then be used to do things like
* get file paths associated with the Activity.
*
* @param cordova The context of the main Activity.
* @param webView The CordovaWebView Cordova is running in.
*/
public void initialize(CordovaInterface cordova,intentFilter);
}
}
项目：Tech-Jalsa
文件：MainActivity.java
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
toolbar = (Toolbar) findViewById(R.id.toolbar);
setSupportActionBar(toolbar);
viewPager = (ViewPager) findViewById(R.id.viewpager);
setupViewPager(viewPager);
viewPager.setoffscreenPageLimit(ITEM_COUNT);
tabLayout = (TabLayout) findViewById(R.id.tabs);
tabLayout.setupWithViewPager(viewPager);
mRegistrationbroadcastReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if (intent.getAction().equals(Config.REGISTRATION_COMPLETE)) {
FirebaseMessaging.getInstance().subscribetoTopic(Config.TOPIC_GLOBAL);
} else if (intent.getAction().equals(Config.PUSH_NOTIFICATION)) {
// new push notification is received
}
}
};
}
项目：rongyunDemo
文件：GroupListActivity.java
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.fr_group_list);
setTitle(R.string.my_groups);
mGroupListView = (ListView) findViewById(R.id.group_listview);
mNoGroups = (TextView) findViewById(R.id.show_no_group);
mSearch = (EditText) findViewById(R.id.group_search);
mTextView = (TextView)findViewById(R.id.foot_group_size);
initData();
broadcastManager.getInstance(mContext).addAction(SealConst.GROUP_LIST_UPDATE,Intent intent) {
initData();
}
});
}
项目：container
文件：VClientImpl.java
private void handleReceiver(ReceiverData data) {
broadcastReceiver.PendingResult result = data.resultData.build();
try {
Context context = createPackageContext(data.component.getPackageName());
Context receiverContext = ContextImpl.getReceiverRestrictedContext.call(context);
String className = data.component.getClassName();
broadcastReceiver receiver = (broadcastReceiver) context.getClassLoader().loadClass(className).newInstance();
mirror.android.content.broadcastReceiver.setPendingResult.call(receiver,result);
data.intent.setExtrasClassLoader(context.getClassLoader());
receiver.onReceive(receiverContext,data.intent);
if (mirror.android.content.broadcastReceiver.getPendingResult.call(receiver) != null) {
result.finish();
}
} catch (Exception e) {
e.printstacktrace();
throw new RuntimeException(
"Unable to start receiver " + data.component
+ ": " + e.toString(),e);
}
VActivityManager.get().broadcastFinish(data.resultData);
}
项目：springreplugin
文件：PluginMgr.java
/**
* @param action
*/
private final void registerReceiverAction(final String action) {
IntentFilter filter = new IntentFilter(action);
LocalbroadcastManager.getInstance(mContext).registerReceiver(new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if (action.equals(intent.getAction())) {
PluginInfo info = intent.getParcelableExtra("obj");
if (info != null) {
switch (action) {
case ACTION_NEW_PLUGIN:
// 非常驻进程上下文
newPluginFound(info,intent.getBooleanExtra(RePluginConstants.KEY_PERSIST_NEED_RESTART,false));
break;
case ACTION_UNINSTALL_PLUGIN:
pluginUninstalled(info);
break;
}
}
}
}
},filter);
}
项目：CXJPadProject
文件：KeyBoardPopWindow.java
/** 注册广播接受来自keyboard的车牌号 */
public void registerReceiver() {
// 输入车牌完成后的intent过滤器
IntentFilter finishFilter = new IntentFilter(INPUT_LICENSE_COMPLETE);
receiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
String license = intent.getStringExtra(INPUT_LICENSE_KEY);
if (license != null && license.length() > 0) {
if (keyboardUtil != null) {
keyboardUtil.hideKeyboard();
}
KeyBoardPopWindow.this.dismiss();
mListener.setLicense(license);
}
}
};
mContext.registerReceiver(receiver,finishFilter);
}
项目：Cable-Android
文件：RecipientPreferenceActivity.java
private void initializeRecipients() {
this.recipients = RecipientFactory.getRecipientsForIds(getActivity(),getArguments().getLongArray(RECIPIENTS_EXTRA),true);
this.recipients.addListener(this);
this.staleReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
recipients.removeListener(RecipientPreferenceFragment.this);
recipients = RecipientFactory.getRecipientsForIds(getActivity(),true);
onModified(recipients);
}
};
IntentFilter intentFilter = new IntentFilter();
intentFilter.addAction(GroupDatabase.DATABASE_UPDATE_ACTION);
intentFilter.addAction(RecipientFactory.RECIPIENT_CLEAR_ACTION);
getActivity().registerReceiver(staleReceiver,intentFilter);
}
public static Observable<Intent> frombroadcast(final Context context,final IntentFilter filter) {
return Observable.create(e -> {
final broadcastReceiver receiver = new broadcastReceiver() {
@Override
public void onReceive(Context context1,Intent intent) {
e.onNext(intent);
}
};
context.registerReceiver(receiver,filter);
e.setdisposable(new disposable() {
@Override
public void dispose() {
context.unregisterReceiver(receiver);
}
@Override
public boolean isdisposed() {
return false;
}
});
});
}
项目：chromium-for-android-56-debug-video
文件：SupervisedUserContentProvider.java
@TargetApi(Build.VERSION_CODES.LOLLIPOP)
private void createEnabledbroadcastReceiver() {
IntentFilter restrictionsFilter = new IntentFilter(
Intent.ACTION_APPLICATION_RESTRICTIONS_CHANGED);
broadcastReceiver restrictionsReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
updateEnabledState();
}
};
getContext().registerReceiver(restrictionsReceiver,restrictionsFilter);
}
项目：letv
文件：LetvApplication.java
public LetvApplication() {
if (HotFix.PREVENT_VERIFY) {
System.out.println(VerifyLoad.class);
}
this.mPluginInstallSuccessReceiver = new broadcastReceiver(this) {
final /* synthetic */ LetvApplication this$0;
{
if (HotFix.PREVENT_VERIFY) {
System.out.println(VerifyLoad.class);
}
this.this$0 = this$0;
}
public void onReceive(Context context,Intent intent) {
String action = intent.getAction();
String data = intent.getDataString();
LogInfo.log("plugin","接收到插件安装成功消息... action = " + action);
if (action.equals(ApkManager.ACTION_PACKAGE_ADDED) && data.substring(data.lastIndexOf("/") + 1).equals("com.letv.android.lite")) {
this.this$0.mIsPluginInitedSuccess = true;
if (this.this$0.mCallLiteIntent != null) {
if (LetvUtils.isTopRunning(this.this$0.getApplicationContext())) {
Toast.makeText(this.this$0.getApplicationContext(),2131100676,0).show();
LogInfo.log("plugin","之前有影视大全的lite调起，现在自动补上...");
LeMessageManager.getInstance().dispatchMessage(BaseApplication.instance,new LeMessage(115,LetvApplication.getInstance().mCallLiteIntent));
JarLaunchUtils.launchLitePlayerDefault(this.this$0.getApplicationContext(),LetvApplication.getInstance().mCallLiteIntent);
} else {
Toast.makeText(this.this$0.getApplicationContext(),2131101586,0).show();
}
}
this.this$0.mCallLiteIntent = null;
}
}
};
}
/**注册广播接收器
* @param context
* @param receiver
* @param filter
* @return
*/
public static broadcastReceiver register(Context context,@Nullable broadcastReceiver receiver,IntentFilter filter) {
Log.i(TAG,"register >>>");
if (context == null || filter == null) {
Log.e(TAG,"register context == null || filter == null >> return;");
return receiver;
}
context.registerReceiver(receiver,filter);
return receiver;
}
项目：WifiUtils
文件：ConnectorUtils.java
static void registerReceiver(@NonNull Context context,@NonNull IntentFilter filter) {
if (receiver != null) {
try {
context.registerReceiver(receiver,filter);
} catch (Exception e) {
}
}
}
/**
* 添加
*
* @param
*/
public void addAction(String action,broadcastReceiver receiver) {
try {
IntentFilter filter = new IntentFilter();
filter.addAction(action);
mContext.registerReceiver(receiver,filter);
receiverMap.put(action,receiver);
} catch (Exception e) {
e.printstacktrace();
}
}
/**
* Unregister a prevIoUsly registered broadcastReceiver. <em>All</em>
* filters that have been registered for this broadcastReceiver will be
* removed.
*
* @param receiver The broadcastReceiver to unregister.
*
* @see #registerReceiver
*/
public void unregisterReceiver(broadcastReceiver receiver) {
if (RePluginFramework.mHostinitialized) {
try {
ProxyLocalbroadcastManagerVar.unregisterReceiver.call(sOrigInstance,receiver);
} catch (Exception e) {
e.printstacktrace();
}
return;
}
synchronized (mReceivers) {
ArrayList<IntentFilter> filters = mReceivers.remove(receiver);
if (filters == null) {
return;
}
for (int i=0; i<filters.size(); i++) {
IntentFilter filter = filters.get(i);
for (int j=0; j<filter.countActions(); j++) {
String action = filter.getAction(j);
ArrayList<ReceiverRecord> receivers = mActions.get(action);
if (receivers != null) {
for (int k=0; k<receivers.size(); k++) {
if (receivers.get(k).receiver == receiver) {
receivers.remove(k);
k--;
}
}
if (receivers.size() <= 0) {
mActions.remove(action);
}
}
}
}
}
}
/**
* Register a receive for any local broadcasts that match the given IntentFilter.
*
* @param receiver The broadcastReceiver to handle the broadcast.
* @param filter Selects the Intent broadcasts to be received.
*
* @see #unregisterReceiver
*/
public void registerReceiver(broadcastReceiver receiver,IntentFilter filter) {
if (RePluginFramework.mHostinitialized) {
try {
ProxyLocalbroadcastManagerVar.registerReceiver.call(sOrigInstance,receiver,filter);
} catch (Exception e) {
e.printstacktrace();
}
return;
}
synchronized (mReceivers) {
ReceiverRecord entry = new ReceiverRecord(filter,receiver);
ArrayList<IntentFilter> filters = mReceivers.get(receiver);
if (filters == null) {
filters = new ArrayList<IntentFilter>(1);
mReceivers.put(receiver,filters);
}
filters.add(filter);
for (int i=0; i<filter.countActions(); i++) {
String action = filter.getAction(i);
ArrayList<ReceiverRecord> entries = mActions.get(action);
if (entries == null) {
entries = new ArrayList<ReceiverRecord>(1);
mActions.put(action,entries);
}
entries.add(entry);
}
}
}
项目：android-PictureInPicture
文件：MainActivity.java
@Override
public void onPictureInPictureModeChanged(
boolean isInPictureInPictureMode,Configuration configuration) {
super.onPictureInPictureModeChanged(isInPictureInPictureMode,configuration);
if (isInPictureInPictureMode) {
// Starts receiving events from action items in PiP mode.
mReceiver =
new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
if (intent == null
|| !ACTION_MEDIA_CONTROL.equals(intent.getAction())) {
return;
}
// This is where we are called back from Picture-in-Picture action
// items.
final int controlType = intent.getIntExtra(EXTRA_CONTROL_TYPE,0);
switch (controlType) {
case CONTROL_TYPE_PLAY:
mMovieView.play();
break;
case CONTROL_TYPE_PAUSE:
mMovieView.pause();
break;
}
}
};
registerReceiver(mReceiver,new IntentFilter(ACTION_MEDIA_CONTROL));
} else {
// We are out of PiP mode. We can stop receiving events from it.
unregisterReceiver(mReceiver);
mReceiver = null;
// Show the video controls if the video is not playing
if (mMovieView != null && !mMovieView.isPlaying()) {
mMovieView.showControls();
}
}
}
项目：MakiLite
文件：PinFragmentActivity.java
项目：MakiLite
文件：PinActivity.java
项目：MakiLite
文件：PinCompatActivity.java
项目：LucaHome-AndroidApplication
文件：ReceiverController.java
public void RegisterReceiver(
@NonNull broadcastReceiver receiver,@NonNull String[] actions) {
IntentFilter downloadStateFilter = new IntentFilter();
for (String action : actions) {
downloadStateFilter.addAction(action);
}
UnregisterReceiver(receiver);
_context.registerReceiver(receiver,downloadStateFilter);
_registeredReceiver.add(receiver);
}
项目：bridgefy-android-samples
文件：ChatActivity.java
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_chat);
ButterKnife.bind(this);
// recover our Peer object
conversationName = getIntent().getStringExtra(INTENT_EXTRA_NAME);
conversationId = getIntent().getStringExtra(INTENT_EXTRA_UUID);
// Configure the Toolbar
Toolbar toolbar = findViewById(R.id.toolbar);
setSupportActionBar(toolbar);
// Enable the Up button
ActionBar ab = getSupportActionBar();
if (ab != null) {
ab.setTitle(conversationName);
ab.setdisplayHomeAsUpEnabled(true);
}
// register the receiver to listen for incoming messages
LocalbroadcastManager.getInstance(getBaseContext())
.registerReceiver(new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
Message message = new Message(intent.getStringExtra(MainActivity.INTENT_EXTRA_MSG));
message.setDeviceName(intent.getStringExtra(MainActivity.INTENT_EXTRA_NAME));
message.setDirection(Message.INCOMING_MESSAGE);
messagesAdapter.addMessage(message);
}
},new IntentFilter(conversationId));
// configure the recyclerview
RecyclerView messagesRecyclerView = findViewById(R.id.message_list);
linearlayoutmanager mlinearlayoutmanager = new linearlayoutmanager(this);
mlinearlayoutmanager.setReverseLayout(true);
messagesRecyclerView.setLayoutManager(mlinearlayoutmanager);
messagesRecyclerView.setAdapter(messagesAdapter);
}
项目：LQRWeChat-master
文件：RecentMessageFragment.java
项目：PrivacyStreams
文件：AlarmScheduler.java
public AlarmScheduler(Context ctx,String actionToken) {
this.ctx = ctx;
am = (AlarmManager) ctx.getSystemService(Context.ALARM_SERVICE);
mAlarmIntent = PendingIntent.getbroadcast(ctx,new Intent(actionToken),0);
mReceiver = new broadcastReceiver() {
@Override
public void onReceive(Context context,Intent intent) {
run();
}
};
ctx.registerReceiver(mReceiver,new IntentFilter(actionToken));
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。