refactor: Move all callers of the obsoleted SychronousRestObjectPoster.BeginPostObject() to the identical SynchronousRestObjectRequester.MakeRequest()
parent
5158ec0913
commit
08dc07dc76
|
@ -173,9 +173,10 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage
|
||||||
{
|
{
|
||||||
if (m_RestURL != "")
|
if (m_RestURL != "")
|
||||||
{
|
{
|
||||||
m_log.DebugFormat("[OFFLINE MESSAGING] Retrieving stored messages for {0}", client.AgentId);
|
m_log.DebugFormat("[OFFLINE MESSAGING]: Retrieving stored messages for {0}", client.AgentId);
|
||||||
|
|
||||||
List<GridInstantMessage> msglist = SynchronousRestObjectPoster.BeginPostObject<UUID, List<GridInstantMessage>>(
|
List<GridInstantMessage> msglist
|
||||||
|
= SynchronousRestObjectRequester.MakeRequest<UUID, List<GridInstantMessage>>(
|
||||||
"POST", m_RestURL + "/RetrieveMessages/", client.AgentId);
|
"POST", m_RestURL + "/RetrieveMessages/", client.AgentId);
|
||||||
|
|
||||||
if (msglist == null)
|
if (msglist == null)
|
||||||
|
@ -203,7 +204,7 @@ namespace OpenSim.Region.CoreModules.Avatar.InstantMessage
|
||||||
if ((im.offline != 0)
|
if ((im.offline != 0)
|
||||||
&& (!im.fromGroup || (im.fromGroup && m_ForwardOfflineGroupMessages)))
|
&& (!im.fromGroup || (im.fromGroup && m_ForwardOfflineGroupMessages)))
|
||||||
{
|
{
|
||||||
bool success = SynchronousRestObjectPoster.BeginPostObject<GridInstantMessage, bool>(
|
bool success = SynchronousRestObjectRequester.MakeRequest<GridInstantMessage, bool>(
|
||||||
"POST", m_RestURL+"/SaveMessage/", im);
|
"POST", m_RestURL+"/SaveMessage/", im);
|
||||||
|
|
||||||
if (im.dialog == (byte)InstantMessageDialog.MessageFromAgent)
|
if (im.dialog == (byte)InstantMessageDialog.MessageFromAgent)
|
||||||
|
|
|
@ -106,7 +106,7 @@ namespace OpenSim.Region.OptionalModules.Scripting.XmlRpcGridRouterModule
|
||||||
info.channel = channel;
|
info.channel = channel;
|
||||||
info.uri = uri;
|
info.uri = uri;
|
||||||
|
|
||||||
bool success = SynchronousRestObjectPoster.BeginPostObject<XmlRpcInfo, bool>(
|
bool success = SynchronousRestObjectRequester.MakeRequest<XmlRpcInfo, bool>(
|
||||||
"POST", m_ServerURI+"/RegisterChannel/", info);
|
"POST", m_ServerURI+"/RegisterChannel/", info);
|
||||||
|
|
||||||
if (!success)
|
if (!success)
|
||||||
|
@ -125,7 +125,7 @@ namespace OpenSim.Region.OptionalModules.Scripting.XmlRpcGridRouterModule
|
||||||
|
|
||||||
if (m_Channels.ContainsKey(itemID))
|
if (m_Channels.ContainsKey(itemID))
|
||||||
{
|
{
|
||||||
bool success = SynchronousRestObjectPoster.BeginPostObject<UUID, bool>(
|
bool success = SynchronousRestObjectRequester.MakeRequest<UUID, bool>(
|
||||||
"POST", m_ServerURI+"/RemoveChannel/", m_Channels[itemID]);
|
"POST", m_ServerURI+"/RemoveChannel/", m_Channels[itemID]);
|
||||||
|
|
||||||
if (!success)
|
if (!success)
|
||||||
|
|
|
@ -326,7 +326,6 @@ namespace OpenSim.Services.HypergridService
|
||||||
// This is recursive!!!!!
|
// This is recursive!!!!!
|
||||||
return TrySendInstantMessage(im, url, false, foreigner);
|
return TrySendInstantMessage(im, url, false, foreigner);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private bool UndeliveredMessage(GridInstantMessage im)
|
private bool UndeliveredMessage(GridInstantMessage im)
|
||||||
|
@ -335,15 +334,14 @@ namespace OpenSim.Services.HypergridService
|
||||||
&& (!im.fromGroup || (im.fromGroup && m_ForwardOfflineGroupMessages)))
|
&& (!im.fromGroup || (im.fromGroup && m_ForwardOfflineGroupMessages)))
|
||||||
{
|
{
|
||||||
m_log.DebugFormat("[HG IM SERVICE]: Message saved");
|
m_log.DebugFormat("[HG IM SERVICE]: Message saved");
|
||||||
return SynchronousRestObjectPoster.BeginPostObject<GridInstantMessage, bool>(
|
|
||||||
|
return SynchronousRestObjectRequester.MakeRequest<GridInstantMessage, bool>(
|
||||||
"POST", m_RestURL + "/SaveMessage/", im);
|
"POST", m_RestURL + "/SaveMessage/", im);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue