如何在Android上接收RemObjects事件
本文关键字:RemObjects 事件 Android | 更新日期: 2023-09-27 18:22:10
让我的Android应用程序接收RemObjects事件时遇到问题。。。
这是Android(java)类:
package no.wolftech.fieldagentforandroid.tools;
import java.net.URI;
import java.util.Date;
import no.wolftech.fieldagentforandroid.AndroidService_AsyncProxy;
import no.wolftech.fieldagentforandroid.FieldAgent;
import no.wolftech.fieldagentforandroid.MonitorService;
import no.wolftech.fieldagentforandroid.OnIdleReportDeliveredEvent;
import no.wolftech.fieldagentforandroid.R;
import no.wolftech.fieldagentforandroid.ROEventsAdapter;
import no.wolftech.fieldagentforandroid.ReportStruct;
import android.content.Context;
import android.content.Intent;
import android.os.Handler;
import android.util.Log;
import com.remobjects.sdk.AsyncRequest;
import com.remobjects.sdk.ClientChannel;
import com.remobjects.sdk.ClientChannel.IClientChannelCallback;
import com.remobjects.sdk.EventNotifier;
import com.remobjects.sdk.EventReceiver;
public class AndroidService
{
final AndroidService_AsyncProxy androidService;
final EventReceiver receiver;
EventNotifier notifier;
private Handler aHandler;
Context context;
URI serverURI;
Boolean result;
public AndroidService()
{
androidService = SetupAndroidService();
aHandler = new Handler();
receiver = SetupEventReceiver();
/*androidService.beginSubscribeToEvents(true, new AsyncRequest.IAsyncRequestCallback()
{
@Override
public void completed(AsyncRequest aRequest)
{
androidService.endSubscribeToEvents(aRequest);
Log.d("AndroidService", "Subscribed to Events");
}
@Override
public void failed(AsyncRequest aRequest, Exception aException)
{
Log.e("AndroidService", "SubscribeToEvents Failed: " + aException.getMessage());
}
});*/
}
public AndroidService_AsyncProxy SetupAndroidService()
{
try
{
context = FieldAgent.getAppContext();
serverURI = new URI(context.getString(R.string.server_adress));
}
catch (Exception e)
{
Log.e("AndroidService", e.getMessage());
}
final AndroidService_AsyncProxy androidService = new AndroidService_AsyncProxy(serverURI);
// Set channel callback
androidService.getProxyClientChannel().setChannelCallback(new IClientChannelCallback() {
@Override
public void requestFailWithException(Exception aException) {
Log.e("AndroidService", "Exception : " + aException.getMessage());
}
@Override
public boolean clientChannelNeedsLogin(Exception aException) {
Log.e("AndroidService", "clientChannelNeedsLogin: " + aException.getMessage());
return false;
}
});
Log.d("AndroidService", "AndroidService Initiated");
return androidService;
}
public EventReceiver SetupEventReceiver()
{
EventReceiver receiver = new EventReceiver(androidService, "AndroidServiceReceiver");
receiver.setChannel(ClientChannel.channelWithURI(serverURI));
receiver.setServiceName(androidService._getInterfaceName());
receiver.setMinPollInterval(1);
receiver.setMaxPollInterval(3);
receiver.addListener(new ROEventsAdapter() {
@Override
public void OnIdleReportDelivered(final OnIdleReportDeliveredEvent aEvent)
{
Log.d("AndroidServiceEventReceiver", "OnIdleReportDelivered");
aHandler.post(new Runnable()
{
@Override
public void run()
{
ReportStruct report = aEvent.get_DeliveredReport();
FieldAgent.setLastReportTime("Last Report Sent " + report.getTime());
Log.d("AndroidServiceEventReceiver", "Stopping MonitorService");
Intent serviceIntent = new Intent(FieldAgent.getAppContext(),
MonitorService.class);
FieldAgent.getAppContext().stopService(serviceIntent);
FieldAgent.setErrorState(FieldAgent.ERRORSTATE_NO_ERROR);
}
});
}
});
Log.d("AndroidService", "EventReceiver Initiated");
return receiver;
}
private void setResult(Boolean inResult)
{
result = inResult;
}
private Boolean getResult()
{
return result;
}
public Boolean SendIdleReport(double latitude, double longitude)
{
Date now = new Date();
androidService.beginAddIdleReport(now, longitude, latitude, "Android Location", true, new AsyncRequest.IAsyncRequestCallback()
{
@Override
public void completed(AsyncRequest aRequest)
{
androidService.endAddIdleReport(aRequest);
Log.d("AndroidService", "IdleReport sent");
setResult(true);
}
@Override
public void failed(AsyncRequest aRequest, Exception aException)
{
Log.e("AndroidService", "AddIdleReport Failed: " + aException.getMessage());
setResult(false);
}
});
return getResult();
}
}
以下是我在服务器上订阅事件的方式:
IAndroidEvents ev = (IAndroidEvents)GetEventSink(typeof(IAndroidEvents), new Guid[] { SessionID });
我还尝试过使用这样的订阅方法:
public virtual bool SubscribeToEvents()
{
try
{
Guid currentSession = SessionID;
EventSinkManager.SubscribeClient(currentSession, typeof(IAndroidEvents));
return true;
}
catch (Exception e)
{
return false;
}
}
但运气不好。通道回调(ClientChannelNeedsLogin)有效,SendIdleReport()有效,但没有事件。。。有人能帮忙吗?
我想明白了,我忘记了这条非常重要的小行:
receiver.start()