diff --git a/src/cpp/ripple/ripple_LedgerConsensus.cpp b/src/cpp/ripple/ripple_LedgerConsensus.cpp
index cd0841e044..0f5106e461 100644
--- a/src/cpp/ripple/ripple_LedgerConsensus.cpp
+++ b/src/cpp/ripple/ripple_LedgerConsensus.cpp
@@ -1043,6 +1043,8 @@ void LedgerConsensus::accept(SHAMap::ref set, LoadEvent::pointer)
 	boost::recursive_mutex::scoped_lock masterLock(theApp->getMasterLock());
 	assert(set->getHash() == mOurPosition->getCurrentHash());
 
+	theApp->getOPs().peekStoredProposals().clear(); // these are now obsolete
+
 	uint32 closeTime = roundCloseTime(mOurPosition->getCloseTime());
 	bool closeTimeCorrect = true;
 	if (closeTime == 0)
diff --git a/src/cpp/ripple/ripple_Peer.cpp b/src/cpp/ripple/ripple_Peer.cpp
index 375e1f9f0f..1b8b2c61e5 100644
--- a/src/cpp/ripple/ripple_Peer.cpp
+++ b/src/cpp/ripple/ripple_Peer.cpp
@@ -1100,11 +1100,7 @@ static void checkPropose(Job& job, boost::shared_ptr<ripple::TMProposeSet> packe
 	}
 
 	if (isTrusted)
-	{
-		theApp->getJobQueue().addJob(jtPROPOSAL_t, "trustedProposal",
-			BIND_TYPE(&NetworkOPs::processTrustedProposal, &theApp->getOPs(),
-				proposal, packet, nodePublic, prevLedger, sigGood));
-	}
+		theApp->getOPs().processTrustedProposal(proposal, packet, nodePublic, prevLedger, sigGood);
 	else if (sigGood && (prevLedger == consensusLCL))
 	{ // relay untrusted proposal
 		WriteLog (lsTRACE, Peer) << "relaying untrusted proposal";